@PublicEvolving public static interface HybridSource.SourceSwitchContext<EnumT>
To derive a start position at switch time, the source can be initialized from context of the previous enumerator. A specific enumerator implementation may carry state such as an end timestamp, that can be used to derive the start position of the next source.
Currently only the previous enumerator is exposed. The context interface allows for backward compatible extension, i.e. additional information about the previous source can be supplied in the future.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.