English | 简体中文
This repository contains the OceanBase connectors for Apache Flink.
Prerequisites
- JDK 8
- Flink 1.15 or later version
This repository contains connectors as following:
| Connector | Description | Document |
|---|---|---|
| Flink Connector: OceanBase | This Connector uses the JDBC driver supported by OceanBase to read data from and write data to OceanBase, and supports MySQL and Oracle compatibility modes. Source supports parallel snapshot read with configurable split strategies. | Source & Sink |
| Flink Connector: OceanBase Direct Load | This Connector uses the direct load API to write data to OceanBase. | Sink |
| Flink Connector: OBKV HBase | This Connector uses the OBKV HBase API to write data to OceanBase. | Sink |
| Flink Connector: OBKV HBase2 | This Connector uses the OBKV HBase API to write data to OceanBase. Compared to flink-connector-obkv-hbase, it is based on flattening and supports features such as dynamic column updates. |
Sink |
We also provide a command line tool for submitting Flink end-to-end tasks, see the CLI docs for details.
There are some community projects which can be used to work with Apache Flink and OceanBase.
| Project | OceanBase Compatible Mode | Supported Features |
|---|---|---|
| Flink Connector JDBC | MySQL, Oracle | Source + Sink |
| Flink CDC | MySQL, Oracle | Source + CDC |
| Apache SeaTunnel | MySQL, Oracle | Source Sink |
Don’t hesitate to ask!
Contact the developers and community at https://ask.oceanbase.com if you need any help.
Open an issue if you found a bug.
See LICENSE for more information.