Package org.apache.flink.connector.testutils.source.reader

Class Summary

Class	Description
SourceReaderTestBase<SplitT extends org.apache.flink.api.connector.source.SourceSplit>	An abstract test class for all the unit tests of SourceReader to inherit.
TestingReaderContext	A testing implementation of the SourceReaderContext.
TestingReaderOutput<E>	A ReaderOutput for testing that collects the emitted records.
TestingSplitEnumeratorContext<SplitT extends org.apache.flink.api.connector.source.SourceSplit>	A test implementation of the SplitEnumeratorContext, with manual, non-concurrent interaction and intercepting of state.
TestingSplitEnumeratorContext.SplitAssignmentState<SplitT extends org.apache.flink.api.connector.source.SourceSplit>	The state of the split assignment for a subtask.