Flink学习第八天——Flink核心的Sink Operator实战_flink实战派

一、Flink编程模型

• 

• Sink 输出源

  • 预定义

    • print
    • writeAsText （过期）

  • 自定义

    • SinkFunction

    • RichSinkFunction

      • Rich相关的api更丰富，多了Open、Close方法，用于初始化连接等

  • flink官方提供 Bundle Connector

    • kafka、ES 等

  • Apache Bahir

    • kafka、ES、Redis等

二、Flink 自定义的SinkFunction 数据源输出案例实战

• 自定义

  • SinkFunction

  • RichSinkFunction

    • Rich相关的api更丰富，多了Open、Close方法，用于初始化连接等

• Flink连接mysql的几种方式（都需要加jdbc驱动）

  • 方式一：自带flink-connector-jdbc 需要加依赖包