Status
...
Page properties | ||
---|---|---|
|
JIRA: FLINK-25756 - Dedicated Opensearch connectors
...
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
- Integrate with Flink Sink API (FLIP-143)
- Integrate with Flink new Source API (FLIP-27)
- Build upon Flink New DynamicTableSink and DynamicTableSinkFactory interfaces (FLIP-95)
- Sink streaming results with checkpointing enabled (at-least-once delivery semantics)
- Integrate with Table API
The Opensearch connectors are largely based on already existing Elasticsearch connectors (more specifically, Elasticsearch 7 flavor) and APIs-wise provide the identical feature set.
Proposed Changes
We propose to introduce dedicated Opensearch connectors (for 1.x and 2.x release lines) in Flink, based on existing Elasticsearch 7 connectors (https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/elasticsearch/).
...