Update Flink_Data_Transformation.md

2019-10-26 20:27:57 +08:00 · 2019-10-26 20:27:57 +08:00 · 649bf7f78a
commit 649bf7f78a
parent 948c0dad74
1 changed files with 2 additions and 2 deletions
--- a/notes/Flink_Data_Transformation.md
+++ b/notes/Flink_Data_Transformation.md
@ -176,10 +176,10 @@ split.select("even").print();
 project 主要用于获取  tuples 中的指定字段集，示例如下：

 ```java
-DataStreamSource<Tuple3<String, Integer, String>> tuple3DataStreamSource = env.fromElements(
+DataStreamSource<Tuple3<String, Integer, String>> 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)