Skip to content

Commit 649bf7f

Browse files
authored
Update Flink_Data_Transformation.md
1 parent 948c0da commit 649bf7f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

notes/Flink_Data_Transformation.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -176,10 +176,10 @@ split.select("even").print();
176176
project 主要用于获取 tuples 中的指定字段集,示例如下:
177177

178178
```java
179-
DataStreamSource<Tuple3<String, Integer, String>> tuple3DataStreamSource = env.fromElements(
179+
DataStreamSource<Tuple3<String, Integer, String>> streamSource = env.fromElements(
180180
new Tuple3<>("li", 22, "2018-09-23"),
181181
new Tuple3<>("ming", 33, "2020-09-23"));
182-
tuple3DataStreamSource.project(0,2).print();
182+
streamSource.project(0,2).print();
183183

184184
// 输出
185185
(li,2018-09-23)

0 commit comments

Comments
 (0)