This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-ml.git
The following commit(s) were added to refs/heads/master by this push: new 4fe67d5 [hotfix] Rename flink-ml-api to flink-ml-core 4fe67d5 is described below commit 4fe67d5c0ba92cd785ac15ddd0cf515efc34262a Author: Dong Lin <lindon...@gmail.com> AuthorDate: Thu Nov 25 20:06:25 2021 +0800 [hotfix] Rename flink-ml-api to flink-ml-core This closes #38. --- {flink-ml-api => flink-ml-core}/pom.xml | 4 ++-- .../src/main/java/org/apache/flink/ml/api}/AlgoOperator.java | 2 +- .../src/main/java/org/apache/flink/ml/api}/Estimator.java | 2 +- .../src/main/java/org/apache/flink/ml/api}/Model.java | 2 +- .../src/main/java/org/apache/flink/ml/api}/Stage.java | 2 +- .../src/main/java/org/apache/flink/ml/api}/Transformer.java | 2 +- .../src/main/java/org/apache/flink/ml/builder}/Pipeline.java | 5 ++++- .../src/main/java/org/apache/flink/ml/builder}/PipelineModel.java | 5 ++++- .../main/java/org/apache/flink/ml/distance/DistanceMeasure.java | 0 .../org/apache/flink/ml/distance/EuclideanDistanceMeasure.java | 0 .../src/main/java/org/apache/flink/ml/linalg/DenseVector.java | 0 .../src/main/java/org/apache/flink/ml/linalg/Vector.java | 0 .../src/main/java/org/apache/flink/ml/linalg/Vectors.java | 0 .../apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java | 0 .../org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfo.java | 0 .../flink/ml/linalg/typeinfo/DenseVectorTypeInfoFactory.java | 0 .../src/main/java/org/apache/flink/ml/param/BooleanParam.java | 0 .../src/main/java/org/apache/flink/ml/param/DoubleArrayParam.java | 0 .../src/main/java/org/apache/flink/ml/param/DoubleParam.java | 0 .../src/main/java/org/apache/flink/ml/param/FloatArrayParam.java | 0 .../src/main/java/org/apache/flink/ml/param/FloatParam.java | 0 .../src/main/java/org/apache/flink/ml/param/IntArrayParam.java | 0 .../src/main/java/org/apache/flink/ml/param/IntParam.java | 0 .../src/main/java/org/apache/flink/ml/param/LongArrayParam.java | 0 .../src/main/java/org/apache/flink/ml/param/LongParam.java | 0 .../src/main/java/org/apache/flink/ml/param/Param.java | 0 .../src/main/java/org/apache/flink/ml/param/ParamValidator.java | 0 .../src/main/java/org/apache/flink/ml/param/ParamValidators.java | 0 .../src/main/java/org/apache/flink/ml/param/StringArrayParam.java | 0 .../src/main/java/org/apache/flink/ml/param/StringParam.java | 0 .../src/main/java/org/apache/flink/ml/param/WithParams.java | 0 .../src/main/java/org/apache/flink/ml/util/ParamUtils.java | 0 .../src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java | 2 +- .../src/test/java/org/apache/flink/ml/api}/ExampleStages.java | 2 +- .../src/test/java/org/apache/flink/ml/api}/PipelineTest.java | 8 +++++--- .../src/test/java/org/apache/flink/ml/api}/StageTest.java | 2 +- flink-ml-lib/pom.xml | 2 +- .../main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java | 2 +- .../java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java | 2 +- flink-ml-uber/pom.xml | 4 ++-- pom.xml | 2 +- 41 files changed, 29 insertions(+), 21 deletions(-) diff --git a/flink-ml-api/pom.xml b/flink-ml-core/pom.xml similarity index 96% rename from flink-ml-api/pom.xml rename to flink-ml-core/pom.xml index b828457..6ed25b7 100644 --- a/flink-ml-api/pom.xml +++ b/flink-ml-core/pom.xml @@ -28,8 +28,8 @@ under the License. <version>0.1-SNAPSHOT</version> </parent> - <artifactId>flink-ml-api</artifactId> - <name>Flink ML : API</name> + <artifactId>flink-ml-core</artifactId> + <name>Flink ML : Core</name> <dependencies> <dependency> diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/AlgoOperator.java b/flink-ml-core/src/main/java/org/apache/flink/ml/api/AlgoOperator.java similarity index 97% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/AlgoOperator.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/api/AlgoOperator.java index 7f2d4b4..3547d22 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/AlgoOperator.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/api/AlgoOperator.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.table.api.Table; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Estimator.java b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Estimator.java similarity index 97% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Estimator.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/api/Estimator.java index bab9c7d..d87ec8b 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Estimator.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Estimator.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.table.api.Table; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Model.java b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Model.java similarity index 97% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Model.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/api/Model.java index e24664b..ad50422 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Model.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Model.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.table.api.Table; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Stage.java b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Stage.java similarity index 98% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Stage.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/api/Stage.java index fa12186..6f072dc 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Stage.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Stage.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.ml.param.WithParams; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Transformer.java b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Transformer.java similarity index 97% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Transformer.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/api/Transformer.java index ec86968..52e4acb 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Transformer.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/api/Transformer.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.annotation.PublicEvolving; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java b/flink-ml-core/src/main/java/org/apache/flink/ml/builder/Pipeline.java similarity index 96% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/builder/Pipeline.java index 94df9f8..408198a 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/builder/Pipeline.java @@ -16,10 +16,13 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.builder; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.annotation.VisibleForTesting; +import org.apache.flink.ml.api.AlgoOperator; +import org.apache.flink.ml.api.Estimator; +import org.apache.flink.ml.api.Stage; import org.apache.flink.ml.param.Param; import org.apache.flink.ml.util.ParamUtils; import org.apache.flink.ml.util.ReadWriteUtils; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java b/flink-ml-core/src/main/java/org/apache/flink/ml/builder/PipelineModel.java similarity index 95% rename from flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/builder/PipelineModel.java index cf11beb..2668f82 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/builder/PipelineModel.java @@ -16,10 +16,13 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.builder; import org.apache.flink.annotation.PublicEvolving; import org.apache.flink.annotation.VisibleForTesting; +import org.apache.flink.ml.api.AlgoOperator; +import org.apache.flink.ml.api.Model; +import org.apache.flink.ml.api.Stage; import org.apache.flink.ml.param.Param; import org.apache.flink.ml.util.ParamUtils; import org.apache.flink.ml.util.ReadWriteUtils; diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java b/flink-ml-core/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java b/flink-ml-core/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/distance/EuclideanDistanceMeasure.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/linalg/DenseVector.java b/flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseVector.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/linalg/DenseVector.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseVector.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vector.java b/flink-ml-core/src/main/java/org/apache/flink/ml/linalg/Vector.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vector.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/linalg/Vector.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vectors.java b/flink-ml-core/src/main/java/org/apache/flink/ml/linalg/Vectors.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vectors.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/linalg/Vectors.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java b/flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfo.java b/flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfo.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfo.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfo.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfoFactory.java b/flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfoFactory.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfoFactory.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorTypeInfoFactory.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/BooleanParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/BooleanParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/BooleanParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/BooleanParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/DoubleArrayParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleArrayParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/DoubleArrayParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleArrayParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/DoubleParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/DoubleParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/DoubleParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/FloatArrayParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/FloatArrayParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/FloatArrayParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/FloatArrayParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/FloatParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/FloatParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/FloatParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/FloatParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/IntArrayParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/IntArrayParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/IntArrayParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/IntArrayParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/IntParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/IntParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/IntParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/IntParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/LongArrayParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/LongArrayParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/LongArrayParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/LongArrayParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/LongParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/LongParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/LongParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/LongParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/Param.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/Param.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/Param.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/Param.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/ParamValidator.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidator.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/ParamValidator.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidator.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/ParamValidators.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/ParamValidators.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/ParamValidators.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/StringArrayParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/StringArrayParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/StringArrayParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/StringArrayParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/StringParam.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/StringParam.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/StringParam.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/StringParam.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/param/WithParams.java b/flink-ml-core/src/main/java/org/apache/flink/ml/param/WithParams.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/param/WithParams.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/param/WithParams.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/util/ParamUtils.java b/flink-ml-core/src/main/java/org/apache/flink/ml/util/ParamUtils.java similarity index 100% rename from flink-ml-api/src/main/java/org/apache/flink/ml/util/ParamUtils.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/util/ParamUtils.java diff --git a/flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java b/flink-ml-core/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java similarity index 99% rename from flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java rename to flink-ml-core/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java index 0179c2a..457cac3 100644 --- a/flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java +++ b/flink-ml-core/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java @@ -18,7 +18,7 @@ package org.apache.flink.ml.util; -import org.apache.flink.ml.api.core.Stage; +import org.apache.flink.ml.api.Stage; import org.apache.flink.ml.param.Param; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.util.InstantiationUtil; diff --git a/flink-ml-api/src/test/java/org/apache/flink/ml/api/core/ExampleStages.java b/flink-ml-core/src/test/java/org/apache/flink/ml/api/ExampleStages.java similarity index 99% rename from flink-ml-api/src/test/java/org/apache/flink/ml/api/core/ExampleStages.java rename to flink-ml-core/src/test/java/org/apache/flink/ml/api/ExampleStages.java index 14b7d50..204d477 100644 --- a/flink-ml-api/src/test/java/org/apache/flink/ml/api/core/ExampleStages.java +++ b/flink-ml-core/src/test/java/org/apache/flink/ml/api/ExampleStages.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.api.common.state.BroadcastState; import org.apache.flink.api.common.state.ListState; diff --git a/flink-ml-api/src/test/java/org/apache/flink/ml/api/core/PipelineTest.java b/flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java similarity index 95% rename from flink-ml-api/src/test/java/org/apache/flink/ml/api/core/PipelineTest.java rename to flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java index 8792455..8ce3fe3 100644 --- a/flink-ml-api/src/test/java/org/apache/flink/ml/api/core/PipelineTest.java +++ b/flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java @@ -16,10 +16,12 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; -import org.apache.flink.ml.api.core.ExampleStages.SumEstimator; -import org.apache.flink.ml.api.core.ExampleStages.SumModel; +import org.apache.flink.ml.api.ExampleStages.SumEstimator; +import org.apache.flink.ml.api.ExampleStages.SumModel; +import org.apache.flink.ml.builder.Pipeline; +import org.apache.flink.ml.builder.PipelineModel; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.Table; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; diff --git a/flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java b/flink-ml-core/src/test/java/org/apache/flink/ml/api/StageTest.java similarity index 99% rename from flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java rename to flink-ml-core/src/test/java/org/apache/flink/ml/api/StageTest.java index fe753d6..6ac630d 100644 --- a/flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java +++ b/flink-ml-core/src/test/java/org/apache/flink/ml/api/StageTest.java @@ -16,7 +16,7 @@ * limitations under the License. */ -package org.apache.flink.ml.api.core; +package org.apache.flink.ml.api; import org.apache.flink.ml.param.BooleanParam; import org.apache.flink.ml.param.DoubleArrayParam; diff --git a/flink-ml-lib/pom.xml b/flink-ml-lib/pom.xml index 86fb7f2..4477ded 100644 --- a/flink-ml-lib/pom.xml +++ b/flink-ml-lib/pom.xml @@ -32,7 +32,7 @@ under the License. <dependencies> <dependency> <groupId>org.apache.flink</groupId> - <artifactId>flink-ml-api</artifactId> + <artifactId>flink-ml-core</artifactId> <version>${project.version}</version> <scope>provided</scope> </dependency> diff --git a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java index a86d7b5..1b08b66 100644 --- a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java +++ b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java @@ -36,7 +36,7 @@ import org.apache.flink.iteration.IterationConfig; import org.apache.flink.iteration.IterationListener; import org.apache.flink.iteration.Iterations; import org.apache.flink.iteration.ReplayableDataStreamList; -import org.apache.flink.ml.api.core.Estimator; +import org.apache.flink.ml.api.Estimator; import org.apache.flink.ml.common.datastream.EndOfStreamWindows; import org.apache.flink.ml.common.datastream.MapPartitionFunctionWrapper; import org.apache.flink.ml.common.iteration.ForwardInputsOfLastRound; diff --git a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java index 015d951..0d2351c 100644 --- a/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java +++ b/flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java @@ -29,7 +29,7 @@ import org.apache.flink.api.java.typeutils.RowTypeInfo; import org.apache.flink.connector.file.sink.FileSink; import org.apache.flink.connector.file.src.FileSource; import org.apache.flink.core.fs.Path; -import org.apache.flink.ml.api.core.Model; +import org.apache.flink.ml.api.Model; import org.apache.flink.ml.common.datastream.TableUtils; import org.apache.flink.ml.distance.DistanceMeasure; import org.apache.flink.ml.linalg.DenseVector; diff --git a/flink-ml-uber/pom.xml b/flink-ml-uber/pom.xml index 2d9fe4c..03897c0 100644 --- a/flink-ml-uber/pom.xml +++ b/flink-ml-uber/pom.xml @@ -37,7 +37,7 @@ under the License. <dependencies> <dependency> <groupId>org.apache.flink</groupId> - <artifactId>flink-ml-api</artifactId> + <artifactId>flink-ml-core</artifactId> <version>${project.version}</version> </dependency> <dependency> @@ -62,7 +62,7 @@ under the License. <configuration> <artifactSet> <includes combine.children="append"> - <include>org.apache.flink:flink-ml-api</include> + <include>org.apache.flink:flink-ml-core</include> <include>org.apache.flink:flink-ml-lib_${scala.binary.version}</include> <include>com.github.fommil.netlib:core</include> </includes> diff --git a/pom.xml b/pom.xml index 1cc7f99..a02e589 100644 --- a/pom.xml +++ b/pom.xml @@ -52,7 +52,7 @@ under the License. </scm> <modules> - <module>flink-ml-api</module> + <module>flink-ml-core</module> <module>flink-ml-iteration</module> <module>flink-ml-lib</module> <module>flink-ml-tests</module>