Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
Motivation
User stories:
As a Flink user, I’d like to use the Table API for the new Kinesis Firehose async sink.
Scope:
- Add a new module for flink-connector-kinesis-data-firehose-table.
- Implement a new KinesisFirehoseDynamicTableSink that uses KinesisDataFirehoseSink Async Implementation and implements AsyncDynamicTableSink.
- The implementation introduces Async Sink configurations as optional options in the table definition, with default values derived from the KinesisDataFirehose default values.
- Unit/Integration testing. modify KinesisTableAPI tests for the new implementation, add unit tests for AsyncDynamicTableSink and KinesisDynamicTableSink and KinesisDynamicTableSinkFactory.
- Java / code-level docs.
- Add documentations for Table Api connector for Kinesis data firehose.
References
More details to be found https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink
Attachments
Issue Links
- Dependent
-
FLINK-24041 [FLIP-171] Generic AsyncSinkBase
- Resolved
- is blocked by
-
FLINK-24228 [FLIP-171] Firehose implementation of Async Sink
- Closed
- is duplicated by
-
FLINK-26057 CLONE - [FLIP-171] Add SQL Client Uber jar for KinesisDataStreams Sink.
- Closed
-
FLINK-26056 CLONE - [FLIP-171] KDS implementation of Async Sink Table API
- Closed
- links to