Flink操练(二十八)之自定义sink
1、代码逻辑实现package day03; import org.apache.flink.streaming.api.datastream.DataStreamSource; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.functions.sink.SinkFunction; /** * @program: Flink_learn * @description: 自定义输出 * @author: Mr.逗 * @create: 2021-09-17 15:01 **/ public class SelfSink { public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); DataStreamSource source = env.fromElements(1, 2, 3); source.addSink(new SinkFunction() { @Override public void invoke(Integer value, Context context) throws Exception { SinkFunction.super.invoke(value,context); System.out.println(value); } }); String name = SelfSink.class.getName(); env.execute(name); } } 2、结果之展示log4j:WARN No appenders could be found for logger (org.apache.flink.api.java.ClosureCleaner). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. 2 3 1