From 3f6fb83078530163e28e2fc9c171428e6c784d2e Mon Sep 17 00:00:00 2001 From: mans2singh Date: Sat, 15 May 2021 15:35:03 -0400 Subject: [PATCH] [[hotfix][docs] Changed argument for toDataStream to Table --- docs/content.zh/docs/dev/table/data_stream_api.md | 6 +++--- docs/content/docs/dev/table/data_stream_api.md | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/docs/content.zh/docs/dev/table/data_stream_api.md b/docs/content.zh/docs/dev/table/data_stream_api.md index 33e43a9d5dc0b..ff154eb286851 100644 --- a/docs/content.zh/docs/dev/table/data_stream_api.md +++ b/docs/content.zh/docs/dev/table/data_stream_api.md @@ -501,15 +501,15 @@ It is a shortcut for `createTemporaryView(String, fromDataStream(DataStream))`. - `createTemporaryView(String, DataStream, Schema)`: Registers the stream under a name to access it in SQL. It is a shortcut for `createTemporaryView(String, fromDataStream(DataStream, Schema))`. -- `toDataStream(DataStream)`: Converts a table into a stream of insert-only changes. The default +- `toDataStream(Table)`: Converts a table into a stream of insert-only changes. The default stream record type is `org.apache.flink.types.Row`. A single rowtime attribute column is written back into the DataStream API's record. Watermarks are propagated as well. -- `toDataStream(DataStream, AbstractDataType)`: Converts a table into a stream of insert-only changes. +- `toDataStream(Table, AbstractDataType)`: Converts a table into a stream of insert-only changes. This method accepts a data type to express the desired stream record type. The planner might insert implicit casts and reorders columns to map columns to fields of the (possibly nested) data type. -- `toDataStream(DataStream, Class)`: A shortcut for `toDataStream(DataStream, DataTypes.of(Class))` +- `toDataStream(Table, Class)`: A shortcut for `toDataStream(Table, DataTypes.of(Class))` to quickly create the desired data type reflectively. From a Table API's perspective, converting from and to DataStream API is similar to reading from or diff --git a/docs/content/docs/dev/table/data_stream_api.md b/docs/content/docs/dev/table/data_stream_api.md index 05b988ac1be48..87828610fbffd 100644 --- a/docs/content/docs/dev/table/data_stream_api.md +++ b/docs/content/docs/dev/table/data_stream_api.md @@ -500,15 +500,15 @@ It is a shortcut for `createTemporaryView(String, fromDataStream(DataStream))`. - `createTemporaryView(String, DataStream, Schema)`: Registers the stream under a name to access it in SQL. It is a shortcut for `createTemporaryView(String, fromDataStream(DataStream, Schema))`. -- `toDataStream(DataStream)`: Converts a table into a stream of insert-only changes. The default +- `toDataStream(Table)`: Converts a table into a stream of insert-only changes. The default stream record type is `org.apache.flink.types.Row`. A single rowtime attribute column is written back into the DataStream API's record. Watermarks are propagated as well. -- `toDataStream(DataStream, AbstractDataType)`: Converts a table into a stream of insert-only changes. +- `toDataStream(Table, AbstractDataType)`: Converts a table into a stream of insert-only changes. This method accepts a data type to express the desired stream record type. The planner might insert implicit casts and reorders columns to map columns to fields of the (possibly nested) data type. -- `toDataStream(DataStream, Class)`: A shortcut for `toDataStream(DataStream, DataTypes.of(Class))` +- `toDataStream(Table, Class)`: A shortcut for `toDataStream(Table, DataTypes.of(Class))` to quickly create the desired data type reflectively. From a Table API's perspective, converting from and to DataStream API is similar to reading from or