Package | Description |
---|---|
org.apache.flink.connector.testframe.external.sink | |
org.apache.flink.connector.testframe.testsuites |
Modifier and Type | Method and Description |
---|---|
TestingSinkSettings |
TestingSinkSettings.Builder.build() |
Modifier and Type | Method and Description |
---|---|
Sink<T,?,?,?> |
DataStreamSinkV1ExternalContext.createSink(TestingSinkSettings sinkSettings)
Create an instance of
Sink satisfying given options. |
Sink<T> |
DataStreamSinkV2ExternalContext.createSink(TestingSinkSettings sinkSettings)
Create an instance of
Sink satisfying given options. |
ExternalSystemDataReader<T> |
DataStreamSinkExternalContext.createSinkDataReader(TestingSinkSettings sinkSettings)
Create a reader for consuming data written to the external system by sink.
|
ExternalSystemDataReader<RowData> |
TableSinkExternalContext.createSinkRowDataReader(TestingSinkSettings sinkOptions,
DataType dataType)
Create a new split in the external system and return a data writer corresponding to the new
split.
|
List<T> |
DataStreamSinkExternalContext.generateTestData(TestingSinkSettings sinkSettings,
long seed)
Generate test data.
|
Map<String,String> |
TableSinkExternalContext.getSinkTableOptions(TestingSinkSettings sinkSettings)
Get table options for building DDL of the connector sink table.
|
Modifier and Type | Method and Description |
---|---|
protected List<T> |
SinkTestSuiteBase.generateTestData(TestingSinkSettings testingSinkSettings,
DataStreamSinkExternalContext<T> externalContext)
Generate a set of test records.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.