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

Classes

• SourceReaderTestBase
• SourceReaderTestBase.ValidatingSourceOutput
• TestingReaderContext
• TestingReaderOutput
• TestingSplitEnumeratorContext
• TestingSplitEnumeratorContext.SplitAssignmentState