org.apache.flink.connector.testframe.testsuites
Classes
SinkTestSuiteBase
SourceTestSuiteBase
SourceTestSuiteBase.CollectIteratorBuilder