Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: update phases of work as per discussion and sugestion in discussion thread

...

  • Integrate with Flink Sink API (FLIP-171)
  • Integrate with Table API (FLIP-95) for Sink. Build upon Flink New DynamicTableSink and DynamicTableSinkFactory Interfaces 

Phase 2

  • Integrate with Flink new Source API (FLIP-27)

Phase 3

  • Integrate with Table API (FLIP-95)
    1for Source. Build upon Flink New DynamicTableSource and DynamicTableSinkFactory Interfaces.
    2. Build upon Flink New DynamicTableSink and DynamicTableSinkFactory Interfaces 

Overall Design


I) Transactional Guarantees

...