org.apache.flink.connector.testutils.source.reader
Classes
SourceReaderTestBase
TestingReaderContext
TestingReaderOutput
TestingSplitEnumeratorContext
TestingSplitEnumeratorContext.SplitAssignmentState