THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 | ||||||
---|---|---|---|---|---|---|
| ||||||
/**
* 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);
} |
...