跟星哥学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…
