Versions Compared

Key

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

...

Introduced API changes And Prototype implementation


First, the FLIP-150 HybridSource support switched start timestamp for next source from previous one. but current all connectors  can not get endTimestamp. So, actually we can not use this function.  So, at this flip we offer this interface.

...

Code Block
languagejava
firstline1
linenumberstrue
/**
 * Unlike predefined start offset in source, this interface allow to apply a dynamic switched
 * timestamp to a source, then source can use this switched timestamp to re-initialize the start
 * offsets. However, it depends on concrete source implementation. A common scenario is that
 * HybridSource's next source use this ability to switch from previous one.
 */
@PublicEvolving
public interface SupportsSwitchedStartTimestamp {

    /** Apply given switched start timestamp to source. */
    void applySwitchedStartTimestamp(long startTimestamp);
}

...