Package org.apache.flink.connector.base.source.reader.splitreader
-
Interface Summary Interface Description SplitReader<E,SplitT extends org.apache.flink.api.connector.source.SourceSplit> An interface used to read from splits. -
Class Summary Class Description SplitsAddition<SplitT> A change to add splits.SplitsChange<SplitT> An abstract class to host splits change.SplitsRemoval<SplitT> A change to remove splits.