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.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.