FlinkErr: Unknown call expression: sum(vc)
创始人
2024-12-28 23:05:40
0

public class OverWindowTableApiTest {     public static void main(String[] args) throws Exception {         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();         env.setParallelism(1);         StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);          DataStreamSource streamSource = env.socketTextStream("hadoop102", 7777);         SingleOutputStreamOperator map = streamSource.map(new MapFunction() {             @Override             public WaterSensor map(String value) throws Exception {                 String[] splits = value.split(",");                  WaterSensor waterSensor = new WaterSensor(splits[0], Long.valueOf(splits[1]), Integer.valueOf(splits[2]));                 return waterSensor;             }         });           // 流转表(指定表结构)         Schema schema = Schema.newBuilder()                 .column("id", "STRING")                 .column("ts", "BIGINT")                 .column("vc", "INT")                 .columnByExpression("pt" , "PROCTIME()")                 .columnByExpression("et", "TO_TIMESTAMP_LTZ(ts, 3)")                 //.watermark("et" , "source_watermark()") // 沿用流中的水位线                 .watermark("et" , "et - INTERVAL '1' SECOND ") // 重新定义水位线                 .build();         Table table = tableEnv.fromDataStream(map, schema);          // API式开窗         OverWindow w1 = Over.partitionBy($("id")).orderBy($("pt")).preceding(UNBOUNDED_ROW).following(CURRENT_ROW).as("w");          table.window(w1)                 .select(                     $("id"), $("ts"), $("vc"), $("et"), $("vc").sum().over($("w")).as("sum_vc")         ).execute().print();          env.execute();     } }

再次运行

 

成功!

相关内容

热门资讯

透视能赢"wepok... 透视能赢"wepoker私人局俱乐部辅助(底牌透视脚本)wepoker软件靠谱么"都是有挂;wepo...
透视ai!wpk俱乐部是真的吗... 透视ai!wpk俱乐部是真的吗,(wPk真的有挂)辅助器(本来有挂)1、wpk俱乐部是真的吗系统规律...
透视系统!wepoker手机版... 透视系统!wepoker手机版透视脚本,(WePoKer方法)都是是真的有挂(详细黑侠破解)亲,关键...
透视挂透视!wpk俱乐部辅助器... 透视挂透视!wpk俱乐部辅助器,(WPk插件)插件辅助(一直是有挂)1、wpk俱乐部辅助器ai机器人...
透视新版"wepok... 透视新版"wepoker透视脚本免费使用视频(底牌透视脚本)we-poker有人玩吗"其实存在有挂;...
透视脚本!aapoker透视脚... 透视脚本!aapoker透视脚本,aapoker辅助软件合法吗,技巧教程(好像是有挂)1、aapok...
透视软件!淘宝买wepoker... 透视软件!淘宝买wepoker透视有用吗,wepoker私人局透视教程(透视果然是有挂);1)淘宝买...
透视辅助!wpk俱乐部是做什么... 透视辅助!wpk俱乐部是做什么的,(wpK透视)其实有挂(详细辅助);1、下载好wpk俱乐部是做什么...
透视ai代打!wepoker作... 透视ai代打!wepoker作弊辅助(WePoKer辅助器)破解辅助插件(真是存在有挂)1、不需要A...
透视脚本!aapoker ai... 透视脚本!aapoker ai插件,aapoker怎么提高中牌率,黑科技教程(都是真的有挂)1、实时...