如何高效接入 Flink：Connecter / Catalog API 核心设计与社区进展

摘要：本文整理自阿里云实时计算团队 Apache Flink Committer 和 PMC Member 任庆盛在 FFA 2023 核心技术专场（二）中的分享，内容主要分为以下四部分：1. Source API 2. Sink API 3. 将 Connecter 集成至 Table /SQL API4. Catalog APITips：点击「阅读原文」在线观看 FFA 2023 会后资料～在正式介绍这些 API 的细节之前，要把这些 API 以它们的分层列了出来，下面一层 API 是 DataStream ，针对 Java 开发一般都是基于 DataStream API 直接开发的。再往上一层就是 Table 和 SQL API ，Connector API 分层也是类似的，如果是想实现一个 Connector 的话其实是一个自底向上的过程。首先需要实现 DataStream 层上的 Source 还有 Sink API ，这个是不可或缺的。在实现了 Source、Sink 之后我们为了支持 Table 、Catalog ，需要在其上针对于 Table 层对于 Connector 提供的 API 来进行再次的开发。那接下来的介绍也会按照这个顺 ………………………………