一、概述

Flink SQL 可以将多种数据源或数据落地端映射为 table

二、实现

2.1. 架构设计

2.1.1. DynamicTableSinkFactory

DynamicTableSinkFactory 的主要方法和 DynamicTableSourceFactory 几乎完全一致

DynamicTableSinkFactory

2.1.2. DynamicTableSink

它具有的方法和DynamicTableSource基本一致，只有一个方法不同：getSinkRuntimeProvider方法。这个方法是sink的关键，返回一个SinkRuntimeProvider。这个类包含如何将表中数据落地的逻辑。

2.2. 实现

2.2.1. PrintSink

PrintSink