Apache Bahir provides extensions to distributed analytics platforms such as Apache Spark™ and Apache Flink®.
This repository is for Apache Flink extensions.
The Bahir community is very open to new connector contributions for Apache Flink.
We ask contributors to first open a JIRA issue describing the planned changes. Please make sure to put "Flink Streaming Connector" in the "Component/s" field.
Once the community has agreed that the planned changes are suitable, you can open a pull request at the "bahir-flink" repository. Please follow the same directory structure as the existing code.
The community will review your changes, giving suggestions how to improve the code until we can merge it to the main repository.
Bahir is built using Apache Maven™. To build Bahir and its example programs, run:
mvn -DskipTests clean install
Testing first requires building Bahir. Once Bahir is built, tests can be run using:
mvn test
王旻安正在维护这个fork以使flink-connector-influxdb2的连接器继续可用，目前正在适配的版本为 flink 1.20 LTS 与 influxdb 2.7 OSS
王旻安模仿 flink-connector-jdbc 重写了整个InfluxDBSource的逻辑以剥离Telegraf，现在InfluxDBSource会根据时间进行分片从指定的bucket-measurement中拉取数据
王旻安模仿 flink-connector-jdbc 修正了InfluxDBSink的部分逻辑，添加了定时flush数据的功能，同时还提供了远程写入失败后在本地创建data point文件的可选开关
mvn -Dmaven.test.skip=true -Dcheckstyle.skip=true install