<ToEnumT extends org.apache.flink.api.connector.source.SplitEnumerator,NextSourceT extends org.apache.flink.api.connector.source.Source<T,?,?>> HybridSource.HybridSourceBuilder<T,ToEnumT> |
HybridSource.HybridSourceBuilder.addSource(NextSourceT source) |
Add pre-configured source (without switch time modification).
|
<ToEnumT extends org.apache.flink.api.connector.source.SplitEnumerator,NextSourceT extends org.apache.flink.api.connector.source.Source<T,?,?>> HybridSource.HybridSourceBuilder<T,ToEnumT> |
HybridSource.HybridSourceBuilder.addSource(HybridSource.SourceFactory<T,NextSourceT,? super EnumT> sourceFactory,
org.apache.flink.api.connector.source.Boundedness boundedness) |
Add source with deferred instantiation based on previous enumerator.
|
static <T,EnumT extends org.apache.flink.api.connector.source.SplitEnumerator> HybridSource.HybridSourceBuilder<T,EnumT> |
HybridSource.builder(org.apache.flink.api.connector.source.Source<T,?,?> firstSource) |
|