Interface HybridSource.SourceSwitchContext<EnumT>

  • Enclosing class:
    HybridSource<T>

    @PublicEvolving
    public static interface HybridSource.SourceSwitchContext<EnumT>
    Context provided to source factory.

    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.

    • Method Detail

      • getPreviousEnumerator

        EnumT getPreviousEnumerator()