Package | Description |
---|---|
org.apache.flink.connector.base.source.hybrid |
Modifier and Type | Method and Description |
---|---|
<ToEnumT extends SplitEnumerator,NextSourceT extends Source<T,?,?>> |
HybridSource.HybridSourceBuilder.addSource(HybridSource.SourceFactory<T,NextSourceT,? super EnumT> sourceFactory,
Boundedness boundedness)
Add source with deferred instantiation based on previous enumerator.
|
<ToEnumT extends SplitEnumerator,NextSourceT extends Source<T,?,?>> |
HybridSource.HybridSourceBuilder.addSource(NextSourceT source)
Add pre-configured source (without switch time modification).
|
static <T,EnumT extends SplitEnumerator> |
HybridSource.builder(Source<T,?,?> firstSource)
Builder for
HybridSource . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.