
Flink中的滑动窗口(SlidingEventTimeWindows)
5星
- 浏览量: 0
- 大小:None
- 文件类型:PDF
简介:
本篇介绍Apache Flink中基于事件时间的滑动窗口机制,探讨其在实时数据流处理中的应用与实现。
def main(args: Array[String]): Unit = {
val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
env.setParallelism(1)
val dstream: DataStream[String] = env.socketTextStream(hadoop1, 7777)
全部评论 (0)
还没有任何评论哟~


