You are viewing an old version of this page. View the current version.

Compare with Current View Page History

Version 1 Next »

Status

Discussion thread
Vote thread
JIRA


Release

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).


Motivation


Public Interfaces


  • 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


Proposed Changes

We propose to introduce dedicated Redshift connectors  in Flink, 

Compatibility, Deprecation, and Migration Plan

The connectors are compatible With respect to Flink, this is new feature, no compatibility, deprecation, and migration plan is expected.

Test Plan

The integration test cases along with end-2-end test suites have been implemented, on par with Redshift connectors test coverage.

Rejected Alternatives


  • No labels