使用 Flink 处理数据时，可以基于 Flink 提供的批式处理（Batch Processing）和流式处理（Streaming Processing）API 来实现，分别能够满足不同场景下应用数据的处理。这两种模式下，输入处理都被抽象为 Source Operator，包含对应输入数据的处理逻辑；输出处理都被抽象为 Sink Operator，包含了对应输出数据的处理逻辑。这里，我们只关注输出的 Sink Operator 实现。 Flink 批式处理模式，运行 Flink Batch Job 时作用在有界的输入数据集上，所以 Job 运行的时间是有时限的，一旦 Job 运行完成，对应的整个数据处理应用就已经结束，比如，输入是一个数据文件，或者一个 Hive SQL 查询对应的结果集，等等。在批式处理模式下处理数据的输出时，主要需要实现一个自定义的 OutputFormat，然后基于该 OutputFormat 来构建一个 Sink，下面看下 OutputFormat 接口的定义，如下所示： @Public public interface OutputFormat<IT> extends Serializable { void configure(Configuration parameters); void open(int taskNumber, int numTasks) throws IO