Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. Each ETL source needs to be assigned a unified Timestamp Barrier
  2. Aggregate Stateful and temporal  temporal operators in Flink ETL job align input and compute data according to the barrier.
  3. Sink operator in ETL job confirms data with barrier to sink tables in Table Store. 

...