Flink-Iceberg-Connector写入流程
2022年10月10日 · 3379 字 · 7 分钟 · Big Data Lake House Stream Compute Storage
Iceberg社区提供了Flink Connector的官方实现，本章源码阅读正是基于此。 写入提交流程总览 Flink 通过 RowData -> distributeStream -> WriterStream -> Committer
2022年10月10日 · 3379 字 · 7 分钟 · Big Data Lake House Stream Compute Storage
Iceberg社区提供了Flink Connector的官方实现，本章源码阅读正是基于此。 写入提交流程总览 Flink 通过 RowData -> distributeStream -> WriterStream -> Committer