sunjincheng121 commented on a change in pull request #7352: [FLINK-11142][docs] Point out fields can be projected out for Position-based Mapping URL: https://github.com/apache/flink/pull/7352#discussion_r243867603
########## File path: docs/dev/table/common.md ########## @@ -830,8 +833,11 @@ val stream: DataStream[(Long, Int)] = ... // convert DataStream into Table with default field names "_1" and "_2" val table: Table = tableEnv.fromDataStream(stream) +// convert DataStream into Table with field "myLong" only +val table: Table = tableEnv.fromDataStream(stream, 'myLong) + // convert DataStream into Table with field names "myLong" and "myInt" -val table: Table = tableEnv.fromDataStream(stream, 'myLong 'myInt) +val table: Table = tableEnv.fromDataStream(stream, 'myLong, 'myInt) Review comment: good catch! ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
