Flink-1.Flink API

Flink API

Flink API，思维导图

Flink API:
    Source:
        Collection
        File
        Kafka
        自定义 implements SourceFunction<T>
    Transform:
        Map
        FlatMap
        Filter
        KeyBy
        滚动聚合算子
        Reduce
        Split 和 Select
        Connect 和 CoMap
        Union
        UDF extends RichMapFunction
    Sink:
        Kafka
        Redis
        Es
        JDBC
    Window:
        时间窗口
            滚动时间窗口
            滑动时间窗口
            会话窗口
        计数窗口
            滚动计数窗口
            滑动计数窗口
        窗口函数
            增量聚合函数
            全窗口函数
    时间
    watermark
    状态:
        算子状态
        键控状态
        状态后端