Uses of Interface
org.apache.flink.connector.testframe.external.ExternalSystemSplitDataWriter
-
Packages that use ExternalSystemSplitDataWriter Package Description org.apache.flink.connector.testframe.external.source org.apache.flink.connector.testframe.testsuites -
-
Uses of ExternalSystemSplitDataWriter in org.apache.flink.connector.testframe.external.source
Methods in org.apache.flink.connector.testframe.external.source that return ExternalSystemSplitDataWriter Modifier and Type Method Description ExternalSystemSplitDataWriter<T>DataStreamSourceExternalContext. createSourceSplitDataWriter(TestingSourceSettings sourceSettings)Create a new split in the external system and return a data writer corresponding to the new split.ExternalSystemSplitDataWriter<org.apache.flink.table.data.RowData>TableSourceExternalContext. createSplitRowDataWriter(TestingSourceSettings sourceOptions, org.apache.flink.table.types.DataType dataType)Create a new split in the external system and return a data writer for writingRowDatacorresponding to the new split. -
Uses of ExternalSystemSplitDataWriter in org.apache.flink.connector.testframe.testsuites
Methods in org.apache.flink.connector.testframe.testsuites with parameters of type ExternalSystemSplitDataWriter Modifier and Type Method Description protected List<T>SourceTestSuiteBase. generateTestDataForWriter(DataStreamSourceExternalContext<T> externalContext, TestingSourceSettings sourceSettings, int splitIndex, ExternalSystemSplitDataWriter<T> writer)Generate a set of split writers.
-