Calendar.getinstance .get TimeInMillis

1.

目录 窗口分配器 时间窗口 计数窗口 全局窗口 窗口函数 增量聚合函数 全窗口函数（full window functions） 增量聚合和全窗口函数的结合使用 Window API 主要由两部分构成：窗口分配器（Window Assigners）和窗口函数（Window Functions） stream.keyBy(<key selector>) .window(<window assigner>) //指明窗口的类型 .aggregate(<window function>) //定义窗口具体的处理逻辑 在window()方法中传入一个窗口分配器； 在aggregate()方法中传入一个窗口函数； 窗口分配器 指定窗口的类型，定义数据应该被“分配”到哪个窗口 方法：.window() 参数：WindowAssigner 返回值：WindowedStream 如果是非按键分区窗口，那么直接调用.windowAll()方法，同样传入一个WindowAssigner，返回的是 AllWindowedStream 滚动处理时间窗口 stream.keyBy(...)...

源算子 创建环境之后，就可以构建数据的业务处理逻辑了，Flink可以从各种来源获取数据，然后构建DataStream进项转换。一般将数据的输入来源称为数据源（data source），而读取数据的算子就叫做源算子（source operator）。所以，Source就是整个程序的输入端。 Flink中添加source的方式，是调用执行环境的 addSource()方法： DataStreamSource<String> stringDataStreamSource = env.addSource(...); DataStreamSource<String> stringDataStreamSource = env.fromSource(...); 参数是一个泛型接口SourceFunction<OUT>，需要实现 SourceFunction 接口；返回 DataStreamSource。这里的 DataStreamSource 类继承自 SingleOutputStreamOperator 类，又进一步继承自 DataStream。所以 很明显，读取数据的 source...