Uses of Interface
org.apache.flink.connector.testframe.external.ExternalSystemDataReader
-
Packages that use ExternalSystemDataReader Package Description org.apache.flink.connector.testframe.external.sink org.apache.flink.connector.testframe.testsuites -
-
Uses of ExternalSystemDataReader in org.apache.flink.connector.testframe.external.sink
Methods in org.apache.flink.connector.testframe.external.sink that return ExternalSystemDataReader Modifier and Type Method Description ExternalSystemDataReader<T>DataStreamSinkExternalContext. createSinkDataReader(TestingSinkSettings sinkSettings)Create a reader for consuming data written to the external system by sink.ExternalSystemDataReader<org.apache.flink.table.data.RowData>TableSinkExternalContext. createSinkRowDataReader(TestingSinkSettings sinkOptions, org.apache.flink.table.types.DataType dataType)Create a new split in the external system and return a data writer corresponding to the new split. -
Uses of ExternalSystemDataReader in org.apache.flink.connector.testframe.testsuites
Methods in org.apache.flink.connector.testframe.testsuites with parameters of type ExternalSystemDataReader Modifier and Type Method Description protected voidSinkTestSuiteBase. checkResultWithSemantic(ExternalSystemDataReader<T> reader, List<T> testData, org.apache.flink.core.execution.CheckpointingMode semantic)Compare the test data with actual data in given semantic.protected voidSinkTestSuiteBase. checkResultWithSemantic(ExternalSystemDataReader<T> reader, List<T> testData, org.apache.flink.streaming.api.CheckpointingMode semantic)Deprecated.
-