Flink-源码学习-FlinkSQL&Table-Table 体系-Connector-TableSink
一、概述
Flink SQL 可以将多种数据源或数据落地端映射为 table
二、实现
2.1. 架构设计
2.1.1. DynamicTableSinkFactory
DynamicTableSinkFactory
的主要方法和 DynamicTableSourceFactory
几乎完全一致

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

2.2. 实现
2.2.1. PrintSink

本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 Joker!
评论
ValineTwikoo