一、概述

SinkFunction 先是被 StreamSink 包装，然后被 DataStreamSink 包装，最后通过 DataStreamSink.getTransformation 作为 operator 添加到 ExecutionEnvironment。
SinkFunction 做为核心接口类，包含一个 invoke 方法，用于数据输出，每条记录都会执行一次 $invoke$ 方法，执行输出操作。