Serialized Form

Package org.apache.flink.connector.base.source.hybrid

Class org.apache.flink.connector.base.source.hybrid.HybridSource extends Object implements Serializable

Serialized Fields

sources

List<E> sources

Class org.apache.flink.connector.base.source.hybrid.HybridSource.HybridSourceBuilder extends Object implements Serializable

Serialized Fields

sources

List<E> sources

Class org.apache.flink.connector.base.source.hybrid.SourceReaderFinishedEvent extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

sourceIndex

int sourceIndex

Class org.apache.flink.connector.base.source.hybrid.SwitchSourceEvent extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

sourceIndex

int sourceIndex

source

org.apache.flink.api.connector.source.Source<T,SplitT extends org.apache.flink.api.connector.source.SourceSplit,EnumChkT> source

finalSource

boolean finalSource