flink-connector-oceanbase
OceanBase Connectors for Apache Flink
| English | 简体中文 |
本仓库包含 OceanBase 的 Flink Connector。
功能
运行环境需要准备
- JDK 8
- Flink 1.15 或后续版本
本仓库提供了如下 Connector：
| Connector | 描述 | 使用文档 |
|---|---|---|
| Flink Connector: OceanBase | 该Connector通过OceanBase支持的JDBC驱动将数据写入OceanBase，支持MySQL 和 Oracle 兼容模式。 | Sink |
| Flink Connector: OceanBase Direct Load | 该Connector通过旁路导入API将数据写入OceanBase。 | Sink |
| Flink Connector: OBKV HBase | 该Connector通过OBKV HBase API将数据写入OceanBase。 | Sink |
其他外部项目
在其他的社区和组织中，也有一些项目可以用于通过 Flink 处理 OceanBase 中的数据。
| Project | OceanBase 兼容模式 | 支持的功能 |
|---|---|---|
| Flink Connector JDBC | MySQL, Oracle | Source + Sink |
| Flink CDC | MySQL, Oracle | Source + CDC |
| Apache SeaTunnel | MySQL, Oracle | Source, Sink |
社区
当你需要帮助时，你可以在 https://ask.oceanbase.com 上找到开发者和其他的社区伙伴。
当你发现项目缺陷时，请在 issues 页面创建一个新的 issue。
许可证
更多信息见 LICENSE。