diff --git a/notes/Flink_Data_Transformation.md b/notes/Flink_Data_Transformation.md index 8f5abb3..769b962 100644 --- a/notes/Flink_Data_Transformation.md +++ b/notes/Flink_Data_Transformation.md @@ -176,10 +176,10 @@ split.select("even").print(); project 主要用于获取 tuples 中的指定字段集,示例如下: ```java -DataStreamSource> tuple3DataStreamSource = env.fromElements( +DataStreamSource> streamSource = env.fromElements( new Tuple3<>("li", 22, "2018-09-23"), new Tuple3<>("ming", 33, "2020-09-23")); -tuple3DataStreamSource.project(0,2).print(); +streamSource.project(0,2).print(); // 输出 (li,2018-09-23)