FlinkSQL之Windowing TVF _生活百科

Windowing TVF
在Flink1.13版本之后出现的替代之前的Group window的产物，官网描述其 is more powerful and effective

//TVF 中的tumble滚动窗口 //tumble(table sensor,descriptor(et),interval '5' second ):作为一张表存在 //特别注意！！！！ //如果在sql中使用了tumble窗口，则一定需要group by,而且group by后一定有window_start,window_end两个字段sql实现TVF的tumble窗口实现
package net.cyan.FlinkSql.TVF; ? import net.cyan.POJO.WaterSensor; import org.apache.flink.api.common.eventtime.WatermarkStrategy; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.Table; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; ? import java.time.Duration; ? import static org.apache.flink.table.api.Expressions.$; ? public class Demo1_Window_TableAPI_Tumble { public static void main(String[] args) { //创建执行环境 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); //创建表的运行环境 StreamTableEnvironment tabEnv = StreamTableEnvironment.create(env); env.setParallelism(1); DataStream<WaterSensor> waterSensorStream = env.fromElements( new WaterSensor("sensor_1", 1000L, 10), new WaterSensor("sensor_1", 2000L, 20), new WaterSensor("sensor_2", 3000L, 30), new WaterSensor("sensor_1", 4000L, 40), new WaterSensor("sensor_1", 5000L, 50), new WaterSensor("sensor_2", 6000L, 60)) .assignTimestampsAndWatermarks( WatermarkStrategy .<WaterSensor>forBoundedOutOfOrderness(Duration.ofSeconds(3)) .withTimestampAssigner((ws, ts) -> ws.getTs()) ? ); //创建table Table table = tabEnv.fromDataStream(waterSensorStream,$("id"),$("ts"),$("vc"),$("et").rowtime()); //创建表 tabEnv.createTemporaryView("sensor",table); //执行sql //TVF 中的tumble滚动窗口 //tumble(table sensor,descriptor(et),interval '5' second ):作为一张表存在 //特别注意！！！！ //如果在sql中使用了tumble窗口，则一定需要group by,而且group by后一定有window_start,window_end两个字段 tabEnv.sqlQuery("select" + "window_start,window_end,id," + "sum(vc) sum_vc" + " from table (tumble(table sensor,descriptor(et),interval '5' second ))" + " group by window_start,window_end,id ") .execute() .print(); ? } }

FlinkSQL之Windowing TVF

经验总结扩展阅读

好听聚财的公司名字聚人聚财的企业名字

爸爸经常打骂孩子怎么办

六款2023年最佳手机推荐手机好用排行榜2023

2022年10月24日是出火的黄道吉日吗 2022年农历九月廿九宜出火吗

纱窗拐角断了如何取出来纱窗拐角断了用什么取代

象鼻山公园旅游攻略掌握三点就可以

巴奴是哪里的品牌

海蛎子能放几天,生海蛎子能放多长时间

11年奇瑞瑞虎油耗多少?

仲孙姓男孩起名大全

亚麻衣服怎么洗不缩水,亚麻面料的衣服这样清洗不会缩水？

宝宝成长中的几个关键时期--1岁以内宝宝

导语：心仪的他就在眼前心仪的男人不唐突的4种搭讪方式，教你把握机会，迈出追爱第一步

韩国眉毛的画法这几个技巧你要知道

疾病 40岁是肠道疾病“高发期”，若想肠道更健康，3个坏习惯要改掉

夏季肌肤护理必知化妆水如何使用

开封清明上河园什么时候开门

再过4天，鸿运当头，高人一等，喜事接踵，横财不断，尽享富贵

谈谈学生早恋的危害不要让自己抱憾终生

二十四史有哪些,二十四史有哪些