This is an automated email from the ASF dual-hosted git repository.
hxb pushed a commit to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
commit 6fed373d4e5eedbd922b9a58843691ea1e5d41ec
Author: huangxingbo <h...@apache.org>
AuthorDate: Fri Jun 24 11:42:35 2022 +0800
[FLINK-28237][python][ml] Improve flink ml python examples in doc
This closes #116.
---
docs/content/docs/operators/classification/knn.md | 1 +
docs/content/docs/operators/classification/logisticregression.md | 1 +
docs/content/docs/operators/classification/naivebayes.md | 1 +
docs/content/docs/operators/clustering/kmeans.md | 1 +
docs/content/docs/operators/feature/onehotencoder.md | 1 +
5 files changed, 5 insertions(+)
diff --git a/docs/content/docs/operators/classification/knn.md
b/docs/content/docs/operators/classification/knn.md
index d1aab59..289b902 100644
--- a/docs/content/docs/operators/classification/knn.md
+++ b/docs/content/docs/operators/classification/knn.md
@@ -121,6 +121,7 @@ output.execute().print();
{{< tab "Python">}}
```python
from pyflink.common import Types
+from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment
from pyflink.ml.core.linalg import Vectors, DenseVectorTypeInfo
diff --git a/docs/content/docs/operators/classification/logisticregression.md
b/docs/content/docs/operators/classification/logisticregression.md
index bbf112e..5a8b119 100644
--- a/docs/content/docs/operators/classification/logisticregression.md
+++ b/docs/content/docs/operators/classification/logisticregression.md
@@ -112,6 +112,7 @@ output.execute().print();
{{< tab "Python">}}
```python
from pyflink.common import Types
+from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment
from pyflink.ml.core.linalg import Vectors, DenseVectorTypeInfo
diff --git a/docs/content/docs/operators/classification/naivebayes.md
b/docs/content/docs/operators/classification/naivebayes.md
index 86f4306..6d50c19 100644
--- a/docs/content/docs/operators/classification/naivebayes.md
+++ b/docs/content/docs/operators/classification/naivebayes.md
@@ -104,6 +104,7 @@ outputTable.execute().print();
{{< tab "Python">}}
```python
from pyflink.common import Types
+from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment
from pyflink.ml.core.linalg import Vectors, DenseVectorTypeInfo
diff --git a/docs/content/docs/operators/clustering/kmeans.md
b/docs/content/docs/operators/clustering/kmeans.md
index 1e56b2f..8ad3560 100644
--- a/docs/content/docs/operators/clustering/kmeans.md
+++ b/docs/content/docs/operators/clustering/kmeans.md
@@ -104,6 +104,7 @@ for (CloseableIterator<Row> it =
output.execute().collect(); it.hasNext(); ) {
{{< tab "Python">}}
```python
from pyflink.common import Types
+from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment
from pyflink.ml.core.linalg import Vectors, DenseVectorTypeInfo
diff --git a/docs/content/docs/operators/feature/onehotencoder.md
b/docs/content/docs/operators/feature/onehotencoder.md
index 1ee44c9..c0a733e 100644
--- a/docs/content/docs/operators/feature/onehotencoder.md
+++ b/docs/content/docs/operators/feature/onehotencoder.md
@@ -82,6 +82,7 @@ outputTable.execute().print();
{{< tab "Python">}}
```python
from pyflink.common import Types, Row
+from pyflink.datastream import StreamExecutionEnvironment
from pyflink.table import StreamTableEnvironment, Table, DataTypes
from pyflink.ml.lib.feature.onehotencoder import OneHotEncoder,
OneHotEncoderModel
