Package | Description |
---|---|
org.apache.flink.connector.testframe.external.source | |
org.apache.flink.connector.testframe.testsuites |
Modifier and Type | Method and Description |
---|---|
TestingSourceSettings |
TestingSourceSettings.Builder.build() |
Modifier and Type | Method and Description |
---|---|
Source<T,?,?> |
DataStreamSourceExternalContext.createSource(TestingSourceSettings sourceSettings)
Create an instance of
Source satisfying given options. |
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. |
List<T> |
DataStreamSourceExternalContext.generateTestData(TestingSourceSettings sourceSettings,
int splitIndex,
long seed)
Generate test data.
|
Map<String,String> |
TableSourceExternalContext.getSourceTableOptions(TestingSourceSettings sourceSettings)
Get table options for building DDL of the connector source table.
|
Modifier and Type | Method and Description |
---|---|
protected List<T> |
SourceTestSuiteBase.generateAndWriteTestData(int splitIndex,
DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings testingSourceSettings)
Generate a set of test records and write it to the given split writer.
|
protected List<T> |
SourceTestSuiteBase.generateTestDataForWriter(DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings sourceSettings,
int splitIndex,
ExternalSystemSplitDataWriter<T> writer)
Generate a set of split writers.
|
protected Source<T,?,?> |
SourceTestSuiteBase.tryCreateSource(DataStreamSourceExternalContext<T> externalContext,
TestingSourceSettings sourceOptions) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.