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
    状态:
        算子状态
        键控状态
        状态后端
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容