RocMarshal commented on a change in pull request #18655:
URL: https://github.com/apache/flink/pull/18655#discussion_r813994890
##########
File path: docs/content.zh/docs/connectors/table/filesystem.md
##########
@@ -24,16 +24,15 @@ specific language governing permissions and limitations
under the License.
-->
-# FileSystem SQL Connector
+<a name="filesystem-sql-connector"></a>
-This connector provides access to partitioned files in filesystems
-supported by the [Flink FileSystem abstraction]({{< ref
"docs/deployment/filesystems/overview" >}}).
+# 文件系统 SQL 连接器
-The file system connector itself is included in Flink and does not require an
additional dependency.
-The corresponding jar can be found in the Flink distribution inside the `/lib`
directory.
-A corresponding format needs to be specified for reading and writing rows from
and to a file system.
+此连接器提供了对 [Flink FileSystem abstraction]({{< ref
"docs/deployment/filesystems/overview" >}}) 支持的文件系统中分区文件的访问。
-The file system connector allows for reading and writing from a local or
distributed filesystem. A filesystem table can be defined as:
+在 Flink 中包含了该文件系统连接器，不需要添加额外的依赖。相应的 jar 包可以在 Flink 工程项目的 `/lib`
目录下找到。从文件系统中读取或者写入行时，需要指定相应的格式。
Review comment:
```suggestion
在 Flink 中包含了该文件系统连接器，不需要添加额外的依赖。相应的 jar 包可以在 Flink 工程项目的 `/lib`
目录下找到。从文件系统中读取或者向文件系统中写入行时，需要指定相应的 format。
```
##########
File path: docs/content.zh/docs/connectors/table/filesystem.md
##########
@@ -43,37 +42,36 @@ CREATE TABLE MyUserTable (
part_name1 INT,
part_name2 STRING
) PARTITIONED BY (part_name1, part_name2) WITH (
- 'connector' = 'filesystem', -- required: specify the connector
- 'path' = 'file:///path/to/whatever', -- required: path to a directory
- 'format' = '...', -- required: file system connector
requires to specify a format,
- -- Please refer to Table Formats
- -- section for more details
- 'partition.default-name' = '...', -- optional: default partition name in
case the dynamic partition
- -- column value is null/empty string
-
- -- optional: the option to enable shuffle data by dynamic partition fields
in sink phase, this can greatly
- -- reduce the number of file for filesystem sink but may lead data skew, the
default value is false.
+ 'connector' = 'filesystem', -- 必选：指定连接器类型
+ 'path' = 'file:///path/to/whatever', -- 必选：指定路径
+ 'format' = '...', -- 必选：文件系统连接器指定格式
+ -- 有关更多详情，请参考 Table Formats
+ 'partition.default-name' = '...', -- 可选：默认的分区名，动态分区模式下分区字段值是 null 或空字符串
+
+ -- 可选：该选项开启了在 sink 阶段通过动态分区字段来 shuffle 数据，该功能可以大大减少文件系统 sink
的文件数，但是可能会导致数据倾斜，默认值是 false
'sink.shuffle-by-partition.enable' = '...',
...
)
```
{{< hint info >}}
-Make sure to include [Flink File System specific dependencies]({{< ref
"docs/deployment/filesystems/overview" >}}).
+确定包含 [Flink File System specific dependencies]({{< ref
"docs/deployment/filesystems/overview" >}}) 。
{{< /hint >}}
{{< hint info >}}
-File system sources for streaming is still under development. In the future,
the community will add support for common streaming use cases, i.e., partition
and directory monitoring.
+基于流的文件系统 sources 仍在开发中。未来，社区将增加对常见的流式用例的支持，例如，对分区和目录的检测等。
Review comment:
`检测`->`监控`
##########
File path: docs/content.zh/docs/connectors/table/filesystem.md
##########
@@ -43,37 +42,36 @@ CREATE TABLE MyUserTable (
part_name1 INT,
part_name2 STRING
) PARTITIONED BY (part_name1, part_name2) WITH (
- 'connector' = 'filesystem', -- required: specify the connector
- 'path' = 'file:///path/to/whatever', -- required: path to a directory
- 'format' = '...', -- required: file system connector
requires to specify a format,
- -- Please refer to Table Formats
- -- section for more details
- 'partition.default-name' = '...', -- optional: default partition name in
case the dynamic partition
- -- column value is null/empty string
-
- -- optional: the option to enable shuffle data by dynamic partition fields
in sink phase, this can greatly
- -- reduce the number of file for filesystem sink but may lead data skew, the
default value is false.
+ 'connector' = 'filesystem', -- 必选：指定连接器类型
+ 'path' = 'file:///path/to/whatever', -- 必选：指定路径
+ 'format' = '...', -- 必选：文件系统连接器指定格式
+ -- 有关更多详情，请参考 Table Formats
+ 'partition.default-name' = '...', -- 可选：默认的分区名，动态分区模式下分区字段值是 null 或空字符串
+
+ -- 可选：该选项开启了在 sink 阶段通过动态分区字段来 shuffle 数据，该功能可以大大减少文件系统 sink
的文件数，但是可能会导致数据倾斜，默认值是 false
'sink.shuffle-by-partition.enable' = '...',
...
)
```
{{< hint info >}}
-Make sure to include [Flink File System specific dependencies]({{< ref
"docs/deployment/filesystems/overview" >}}).
+确定包含 [Flink File System specific dependencies]({{< ref
"docs/deployment/filesystems/overview" >}}) 。
Review comment:
确定 -> 请确保
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
