apache_ali

Flink

druid(1) Java基础(2) JAVA并发(1) JVM(4) mybatis(3) Mysql(1) Netty(1) Pulsar(1) RESTful API(2) zookeeper(1) 并发编程(4) 微服务(1)

/ 注册

全部文章 / Flink （共3篇）

Flink学习-广播状态

什么是广播状态 Broadcast State是Flink支持的一种Operator State。使用Broadcast State，可以在Flink程序的一个Stream中输入数据记录，然后将这些数据记录广播（Broadcast）到下游的每个Task中，使得这些数据记录能够为所有的Task所共享，...

Flink广播

2020-05-22

0 741

Flink学习-窗口Window

Window 窗口是什么 Windows 是处理无限流的核心。Windows 将流分成有限大小的“存储桶”，我们可以在其上应用计算。Flink 是一个优秀的流计算引擎，数据是源源不断的，它认为批处理 Batch 是一种特殊的流计算，在流中分割出一个个窗口，每个窗口相当于有限大小的空间，汇聚了待处理的...

Flink窗口

2020-05-19

0 930

Flink学习-Timestamps / Watermarks

Timestamps Flink的时间一共分为：Processing Time（处理时间）、Event Time （事件时间）和 Ingestion Time（摄取时间） Event Time 应用程序填装数据，塞入的时间。也就是数据本身携带的时间 Ingestion Time Flink数据源...

Flink时间与水印 Flink

2020-05-19

0 800