【Flink】Flink 2023 如何高效接入 Flink：Flink Connector / Catalog API 核心设计_flink 支持connector

作者：运维做开发 | 2024-07-26 17:03:52

踩

flink 支持connector

在这里插入图片描述

1.概述

视频：如何高效接入 Flink：Flink Connector / Catalog API 核心设计

在介绍之前Flink Connector，我们先看看目前的API分层
在这里插入图片描述
最下层是DataStream API，然后上层是Table 和SQL API，如果我们想开发Catalog API 那么也是一个自底向上的过程，在最下面是Source API和SInk API，为了支持Table，因此我们在上面开发了DynamicTableSource和DynamicTableSink,然后最上面是Catalog API。

2.Source API

在这里插入图片描述
老的API我们这里就不说了，这些会在最新的2.x版本被移除，新版的Source API 采用主从的架构，这个和我们FLink集群的架构很相似。这里分成2各部分，SplitEnu

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/运维做开发/article/detail/886352