From 649bf7f78ac475a89fcf5be932b4db8dc7d9d43d Mon Sep 17 00:00:00 2001 From: heibaiying <31504331+heibaiying@users.noreply.github.com> Date: Sat, 26 Oct 2019 20:27:57 +0800 Subject: [PATCH] Update Flink_Data_Transformation.md --- notes/Flink_Data_Transformation.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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)