13-Flink 核心知识 Sink Operator速览

• Flink编程模型
  
• Sink 输出源
  • 预定义
    • print
    • writeAsText （过期）
  • 自定义
    • SinkFunction
    • RichSinkFunction
      • Rich相关的api更丰富，多了Open、Close方法，用于初始化连接等
  • flink官方提供 Bundle Connector
    • kafka、ES 等
  • Apache Bahir
    • kafka、ES、Redis等
• 预定义Sink输出实战

    public static void main(String[] args) throws Exception {

        //构建执行任务环境以及任务的启动的入口, 存储全局相关的参数
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setRuntimeMode(RuntimeExecutionMode.AUTOMATIC);
        env.setParallelism(2);

        DataStream<VideoOrder> videoOrderDS = env.addSource(new VideoOrderSource());

        DataStream<VideoOrder> filterDS = videoOrderDS.filter(new FilterFunction<VideoOrder>() {
            @Override
            public boolean filter(VideoOrder videoOrder) throws Exception {
                return videoOrder.getMoney() > 5;
            }
        });

        filterDS.printToErr();
        filterDS.print();

        //DataStream需要调用execute,可以取个名称
        env.execute("sink job");
    }