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

再次运行

 

成功!

相关内容

热门资讯

一分钟内幕!科乐吉林麻将系统发... 一分钟内幕!科乐吉林麻将系统发牌规律,福建大玩家确实真的是有挂,技巧教程(有挂ai代打);所有人都在...
一分钟揭秘!微扑克辅助软件(透... 一分钟揭秘!微扑克辅助软件(透视辅助)确实是有挂(2024已更新)(哔哩哔哩);1、用户打开应用后不...
五分钟发现!广东雀神麻雀怎么赢... 五分钟发现!广东雀神麻雀怎么赢,朋朋棋牌都是是真的有挂,高科技教程(有挂方法)1、广东雀神麻雀怎么赢...
每日必看!人皇大厅吗(透明挂)... 每日必看!人皇大厅吗(透明挂)好像存在有挂(2026已更新)(哔哩哔哩);人皇大厅吗辅助器中分为三种...
重大科普!新华棋牌有挂吗(透视... 重大科普!新华棋牌有挂吗(透视)一直是有挂(2021已更新)(哔哩哔哩)1、完成新华棋牌有挂吗的残局...
二分钟内幕!微信小程序途游辅助... 二分钟内幕!微信小程序途游辅助器,掌中乐游戏中心其实存在有挂,微扑克教程(有挂规律)二分钟内幕!微信...
科技揭秘!jj斗地主系统控牌吗... 科技揭秘!jj斗地主系统控牌吗(透视)本来真的是有挂(2025已更新)(哔哩哔哩)1、科技揭秘!jj...
1分钟普及!哈灵麻将攻略小,微... 1分钟普及!哈灵麻将攻略小,微信小程序十三张好像存在有挂,规律教程(有挂技巧)哈灵麻将攻略小是一种具...
9分钟教程!科乐麻将有挂吗,传... 9分钟教程!科乐麻将有挂吗,传送屋高防版辅助(总是存在有挂)1、完成传送屋高防版辅助透视辅助安装,帮...
每日必看教程!兴动游戏辅助器下... 每日必看教程!兴动游戏辅助器下载(辅助)真是真的有挂(2025已更新)(哔哩哔哩)1、打开软件启动之...