跟星哥学Flink
-
12.Flink窗口算子(一)
1.1 Window Assinger 当调用window或windowAll方法时,所传入的参数就是Window Assigner(窗口分配器),其作用是决定划分什么样…
-
11.Flink窗口的分类
1 Flink的Window可以分成两类: GlobalWindow:按照指定的数据条数生成一个Window,与时间无关。 TimeWindow:按照时间生成Window,可以根据…
-
10.Flink的窗口和时间类型
1 窗口运算 流式计算是一种被设计用于处理无限数据集的数据计算引擎,所谓无限数据集是指一种源源不断的数据流抽象成的集合。而Window就是一种将无限数据集切分成多个有限数…
-
09.Flink的Transformation(三)
1 split拆分(DataStream → SplitStream) 该方法是将一个DataStream中的数据流打上不同的标签,逻辑的拆分成多个不同类型的流,返回一个新的Spl…
-
08.Flink的Transformation(二)
1 keyBy按key分组(DataStream → KeyedStream) 下面的例子是将一行字符串进行flatMap切分成多个单词,然后将单词和1放入到Tuple2…
-
07.Flink的Transformation(一)
1 map映射(DataStream → DataStream) 该方法是将一个DataStream调用map方法返回一个新的DataStream。本质是将该DataSt…
-
06.Flink的常用Sink
1.1 Data Sink 数据输出 经过一系列Transformation转换操作后,最后一定要调用Sink操作,才会形成一个完整的DataFlow拓扑。只有…
-
05.Flink本地模式添加web页面
将flink提交到集群中运行,可以看到job的的执行计划、占用的资源情况、Task的数量和并行度、内存、checkpoint等信息。但是将必须先job打成jar包,然后通过web页…
-
04.Flink的常用Source
1.1 Data Source数据源 在实时计算DataStream API中,Source是用来获取外部数据源的操作,按照获取数据的方式,可以分为:基于集合的Sourc…