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();     } }

再次运行

 

成功!

相关内容

热门资讯

透视科技!德普辅助器辅助器怎么... 透视科技!德普辅助器辅助器怎么用, (德普)切实真的是有挂(透视)透视辅助插件(有挂规律)1、实时德...
透视辅助!wpk官网下载链接,... 透视辅助!wpk官网下载链接,(wpK)竟然是真的有挂(透视)辅助软件(有挂教程)一、wpk官网下载...
透视数据!约局吧辅助器,红龙p... 透视数据!约局吧辅助器,红龙poker辅助,介绍教程(有挂教程)约局吧辅助器辅助器中分为三种模型:约...
透视辅助器!wepoker透视... 透视辅助器!wepoker透视脚本苹果版,(wepoker)本来是真的有挂(透视)辅助分析器(有挂细...
透视辅助!德普之星透视辅助软件... 透视辅助!德普之星透视辅助软件激活码, (德普)本来有挂(透视)透视辅助软件激活码(有挂解密);1、...
透视辅助!wpk透视是真的假的... 透视辅助!wpk透视是真的假的,(wpK)好像真的有挂(透视)免费辅助(有挂详情);1)wpk透视是...
透视底牌!wepoker高级辅... 透视底牌!wepoker高级辅助,(WEPOKER)果然是有挂(透视)买脚本靠谱(有挂攻略)1、让任...
透视有挂!佛手在线大菠萝为什么... 透视有挂!佛手在线大菠萝为什么都输,佛手大菠萝辅助,揭秘教程(有挂详情);1)佛手在线大菠萝为什么都...
透视辅助!wpk辅助哪里买,(... 透视辅助!wpk辅助哪里买,(wpK)原来真的有挂(透视)透视插件(有挂内幕)1、下载好wpk辅助哪...
透视安装!德普辅助软件, (德... 透视安装!德普辅助软件, (德普)切实真的有挂(透视)私人局辅助免费(有挂细节);1、许多玩家不知道...