Flink Connector for ByteHouse 连接器专门用于通过 Flink 将数据加载到 ByteHouse。
Flink Connector 可以通过 Table API&SQL 和 Flink 的 DataStreamAPI 两种方式连接ByteHouse并处理数据。

使用说明

您可以参考通过 Flink Connector驱动导入，获取连接到ByteHouse的使用方法。

驱动下载

Flink SQL 驱动

本地下载

Flink 版本	备注	驱动程序	发布日期
1.18		flink-sql-connector-bytehouse-ce-1.27.45-1.18.jar 未知大小	2024-04-07
1.16		flink-sql-connector-bytehouse-ce_2.12-1.27.100_snapshot7-1.16.jar 未知大小	2024-09-02
1.15		flink-sql-connector-bytehouse-ce-1.27.74-1.15.jar 未知大小	2024-05-19
1.13	Scala版本： 2.11及以上	flink-sql-connector-bytehouse-ce-1.27.43-1.13.jar 未知大小	2024-03-25

Maven依赖

对于要使用 Flink connector 连接器进行编译的 Maven 项目，请将以下依赖项添加到项目的pom.xml文件中。与 Flink 发行版的关联 Scala 版本相对应。${flink-sql-connector-bytehouse-ce.version}可以设置为所需的 Flink connector 连接器版本。

<dependency>
    <groupId>com.bytedance.bytehouse</groupId>
    <artifactId>flink-sql-connector-bytehouse-ce</artifactId>
    <version>${flink-sql-connector-bytehouse-ce.version}</version>
</dependency>

Flink DataStream API 驱动

驱动版本	匹配 Flink版本	备注	下载链接
0.4	1.15 及以上版本	Java 8 及以上版本	flinkDataStreamApiPlayground-0.4-SNAPSHOT.jar 未知大小