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更新快且高清...
每日必看!智星德州菠萝外挂检测... 每日必看!智星德州菠萝外挂检测(辅助挂)软件透明挂(有挂教学)-哔哩哔哩1、玩家可以在智星德州菠萝外...
透视透明挂!轰趴十三水有后台(... 轰趴十三水有后台赢率提升策略‌;透视透明挂!轰趴十三水有后台(辅助挂)软件透明挂(有挂详情)-哔哩哔...
发现玩家!德扑ai助手软件(辅... 发现玩家!德扑ai助手软件(辅助挂)透视辅助(有挂教学)-哔哩哔哩;玩家在德扑ai助手软件中需先进行...
一分钟了解!x-poker辅助... 一分钟了解!x-poker辅助软件(辅助挂)辅助透视(有挂攻略)-哔哩哔哩1、每一步都需要思考,不同...
一分钟揭秘!德州最新辅助器(辅... 一分钟揭秘!德州最新辅助器(辅助挂)透视辅助(有挂攻略)-哔哩哔哩;德州最新辅助器最新版本免费下载安...
玩家攻略推荐!德州辅助(辅助挂... 玩家攻略推荐!德州辅助(辅助挂)辅助透视(有挂了解)-哔哩哔哩是由北京得德州辅助黑科技有限公司精心研...
揭秘真相!pokernow德州... 《揭秘真相!pokernow德州(辅助挂)辅助透视(有挂介绍)-哔哩哔哩》 pokernow德州软件...
五分钟了解!德州之星辅助器(辅... 五分钟了解!德州之星辅助器(辅助挂)辅助透视(有挂透明)-哔哩哔哩1、很好的工具软件,可以解锁游戏的...
推荐一款!pokermaste... 1、推荐一款!pokermaster有外挂(辅助挂)透视辅助(有挂教学)-哔哩哔哩;详细教程。2、p...