标签:getSecurityId watermark keyBy window snapshot 开窗 streamOperator DataStreamApi
watermark 设置的方式
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource<Snapshot> dataStreamSource = env.addSource(new SourceFormClickhouse2());
// 设置watermark
WatermarkStrategy<Snapshot> snapshotWatermarkStrategy =
WatermarkStrategy.<Snapshot>forBoundedOutOfOrderness(Duration.ofSeconds(10)).
withTimestampAssigner((s, timestamp) -> DateUtil.dateToStamp(s.getDateTime()));
// 引入watermark
SingleOutputStreamOperator<Snapshot> streamOperator = dataStreamSource.assignTimestampsAndWatermarks(snapshotWatermarkStrategy);
开窗 window (key 分组)
多个字段想分组,如何设置。
之前版本 有 keyBy(“field1,field2,field3”) 这种方法已经废弃。
1、方式一
使用元组来实现多个字段keyBy
streamOperator.keyBy(snapshot -> Tuple2.of(snapshot.getHsSecurityId(), snapshot.getSecurityId()))
.window(TumblingEventTimeWindows.of(Time.seconds(15)))
.max("highPx")
.print();
2、方式二
这种写法性能差些,也可以实现。
streamOperator.keyBy(snapshot -> snapshot.getSecurityId())
.keyBy(s->s.getHsSecurityId())
.window(TumblingEventTimeWindows.of(Time.seconds(15)))
.max("highPx")
.print();
3、方式三
使用对象构造
streamOperator.keyBy(snapshot -> new FieldSorting(snapshot.getSecurityId(),snapshot.getSecurityId()))
.window(TumblingEventTimeWindows.of(Time.seconds(15)))
.max("highPx")
.print();
标签:getSecurityId,watermark,keyBy,window,snapshot,开窗,streamOperator,DataStreamApi 来源: https://blog.csdn.net/weixin_43975771/article/details/120853178
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。