You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2021/11/26 08:08:07 UTC
[flink-ml] branch master updated: [hotfix] Rename flink-ml-api to flink-ml-core
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 <li...@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>