You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/09/03 09:18:30 UTC
[flink] branch release-1.10 updated: [FLINK-19105][docs] Fix
documentation errors about FileSystem usage
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new 41fa48b [FLINK-19105][docs] Fix documentation errors about FileSystem usage
41fa48b is described below
commit 41fa48b058e28986be9f067592014dcb18723dcd
Author: Jimmy.Zhou <zy...@163.com>
AuthorDate: Tue Sep 1 17:23:02 2020 +0800
[FLINK-19105][docs] Fix documentation errors about FileSystem usage
This closes #13297.
---
docs/dev/table/common.md | 24 ++++++++++++------------
docs/dev/table/common.zh.md | 24 ++++++++++++------------
docs/dev/table/sql/queries.md | 4 ++--
docs/dev/table/sql/queries.zh.md | 4 ++--
4 files changed, 28 insertions(+), 28 deletions(-)
diff --git a/docs/dev/table/common.md b/docs/dev/table/common.md
index c2b579c..ca49ab2 100644
--- a/docs/dev/table/common.md
+++ b/docs/dev/table/common.md
@@ -760,9 +760,9 @@ TableEnvironment tableEnv = ...; // see "Create a TableEnvironment" section
final Schema schema = new Schema()
.field("a", DataTypes.INT())
.field("b", DataTypes.STRING())
- .field("c", DataTypes.LONG());
+ .field("c", DataTypes.BIGINT());
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(new Csv().fieldDelimiter('|').deriveSchema())
.withSchema(schema)
.createTemporaryTable("CsvSinkTable");
@@ -785,9 +785,9 @@ val tableEnv = ... // see "Create a TableEnvironment" section
val schema = new Schema()
.field("a", DataTypes.INT())
.field("b", DataTypes.STRING())
- .field("c", DataTypes.LONG())
+ .field("c", DataTypes.BIGINT())
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(new Csv().fieldDelimiter('|').deriveSchema())
.withSchema(schema)
.createTemporaryTable("CsvSinkTable")
@@ -1649,19 +1649,19 @@ final Schema schema = new Schema()
.field("count", DataTypes.INT())
.field("word", DataTypes.STRING());
-tEnv.connect(new FileSystem("/source/path1"))
+tEnv.connect(new FileSystem().path("/source/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource1");
-tEnv.connect(new FileSystem("/source/path2"))
+tEnv.connect(new FileSystem().path("/source/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource2");
-tEnv.connect(new FileSystem("/sink/path1"))
+tEnv.connect(new FileSystem().path("/sink/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink1");
-tEnv.connect(new FileSystem("/sink/path2"))
+tEnv.connect(new FileSystem().path("/sink/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink2");
@@ -1687,19 +1687,19 @@ val schema = new Schema()
.field("count", DataTypes.INT())
.field("word", DataTypes.STRING())
-tEnv.connect(new FileSystem("/source/path1"))
+tEnv.connect(new FileSystem().path("/source/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource1")
-tEnv.connect(new FileSystem("/source/path2"))
+tEnv.connect(new FileSystem().path("/source/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource2")
-tEnv.connect(new FileSystem("/sink/path1"))
+tEnv.connect(new FileSystem().path("/sink/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink1")
-tEnv.connect(new FileSystem("/sink/path2"))
+tEnv.connect(new FileSystem().path("/sink/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink2")
diff --git a/docs/dev/table/common.zh.md b/docs/dev/table/common.zh.md
index c2b579c..ca49ab2 100644
--- a/docs/dev/table/common.zh.md
+++ b/docs/dev/table/common.zh.md
@@ -760,9 +760,9 @@ TableEnvironment tableEnv = ...; // see "Create a TableEnvironment" section
final Schema schema = new Schema()
.field("a", DataTypes.INT())
.field("b", DataTypes.STRING())
- .field("c", DataTypes.LONG());
+ .field("c", DataTypes.BIGINT());
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(new Csv().fieldDelimiter('|').deriveSchema())
.withSchema(schema)
.createTemporaryTable("CsvSinkTable");
@@ -785,9 +785,9 @@ val tableEnv = ... // see "Create a TableEnvironment" section
val schema = new Schema()
.field("a", DataTypes.INT())
.field("b", DataTypes.STRING())
- .field("c", DataTypes.LONG())
+ .field("c", DataTypes.BIGINT())
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(new Csv().fieldDelimiter('|').deriveSchema())
.withSchema(schema)
.createTemporaryTable("CsvSinkTable")
@@ -1649,19 +1649,19 @@ final Schema schema = new Schema()
.field("count", DataTypes.INT())
.field("word", DataTypes.STRING());
-tEnv.connect(new FileSystem("/source/path1"))
+tEnv.connect(new FileSystem().path("/source/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource1");
-tEnv.connect(new FileSystem("/source/path2"))
+tEnv.connect(new FileSystem().path("/source/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource2");
-tEnv.connect(new FileSystem("/sink/path1"))
+tEnv.connect(new FileSystem().path("/sink/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink1");
-tEnv.connect(new FileSystem("/sink/path2"))
+tEnv.connect(new FileSystem().path("/sink/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink2");
@@ -1687,19 +1687,19 @@ val schema = new Schema()
.field("count", DataTypes.INT())
.field("word", DataTypes.STRING())
-tEnv.connect(new FileSystem("/source/path1"))
+tEnv.connect(new FileSystem().path("/source/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource1")
-tEnv.connect(new FileSystem("/source/path2"))
+tEnv.connect(new FileSystem().path("/source/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySource2")
-tEnv.connect(new FileSystem("/sink/path1"))
+tEnv.connect(new FileSystem().path("/sink/path1"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink1")
-tEnv.connect(new FileSystem("/sink/path2"))
+tEnv.connect(new FileSystem().path("/sink/path2"))
.withFormat(new Csv().deriveSchema())
.withSchema(schema)
.createTemporaryTable("MySink2")
diff --git a/docs/dev/table/sql/queries.md b/docs/dev/table/sql/queries.md
index eba6135..1def79c 100644
--- a/docs/dev/table/sql/queries.md
+++ b/docs/dev/table/sql/queries.md
@@ -64,7 +64,7 @@ final Schema schema = new Schema()
.field("product", DataTypes.STRING())
.field("amount", DataTypes.INT());
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(...)
.withSchema(schema)
.createTemporaryTable("RubberOrders");
@@ -101,7 +101,7 @@ val schema = new Schema()
.field("product", DataTypes.STRING())
.field("amount", DataTypes.INT())
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(...)
.withSchema(schema)
.createTemporaryTable("RubberOrders")
diff --git a/docs/dev/table/sql/queries.zh.md b/docs/dev/table/sql/queries.zh.md
index 711f15c..75f8a67 100644
--- a/docs/dev/table/sql/queries.zh.md
+++ b/docs/dev/table/sql/queries.zh.md
@@ -64,7 +64,7 @@ final Schema schema = new Schema()
.field("product", DataTypes.STRING())
.field("amount", DataTypes.INT());
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(...)
.withSchema(schema)
.createTemporaryTable("RubberOrders");
@@ -101,7 +101,7 @@ val schema = new Schema()
.field("product", DataTypes.STRING())
.field("amount", DataTypes.INT())
-tableEnv.connect(new FileSystem("/path/to/file"))
+tableEnv.connect(new FileSystem().path("/path/to/file"))
.withFormat(...)
.withSchema(schema)
.createTemporaryTable("RubberOrders")