Package | Description |
---|---|
org.apache.flink.connector.testframe.external.source | |
org.apache.flink.connector.testframe.testsuites |
Modifier and Type | Method and 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<RowData> |
TableSourceExternalContext.createSplitRowDataWriter(TestingSourceSettings sourceOptions,
DataType dataType)
Create a new split in the external system and return a data writer for writing
RowData corresponding to the new split. |
Modifier and Type | Method and Description |
---|---|
protected List<T> |
SourceTestSuiteBase.generateTestDataForWriter(DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings sourceSettings,
int splitIndex,
ExternalSystemSplitDataWriter<T> writer)
Generate a set of split writers.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.