Package org.apache.flink.cdc.connectors.values.source

Class ValuesDataSourceHelper

java.lang.Object

org.apache.flink.cdc.connectors.values.source.ValuesDataSourceHelper

public class ValuesDataSourceHelper
extends Object

A helper class for ValuesDataSource to build events of each split.

the last list of getSourceEvents method is defined as the split for incremental stage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ValuesDataSourceHelper.EventSetId	Different situations for creating sourceEvents, ValuesDataSourceOptions.EVENT_SET_ID.

Field Summary

Fields

Modifier and Type	Field	Description
static TableId	TABLE_1
static TableId	TABLE_2

Constructor Summary

Constructors

Constructor	Description
ValuesDataSourceHelper()

Method Summary

Modifier and Type	Method	Description
static List<List<Event>>	appendOnlyBlobTable()
static List<List<Event>>	complexColumnNameTable()
static List<List<Event>>	getSourceEvents()
static List<List<Event>>	multiSplitSingleBatchTable()
static List<List<Event>>	multiSplitsSingleTable()
static void	setSourceEvents(List<List<Event>> customSourceEvents)	set sourceEvents using custom events.
static void	setSourceEvents(ValuesDataSourceHelper.EventSetId eventType)	set sourceEvents using predefined events.
static List<List<Event>>	singleSplitMultiBatchTable()
static List<List<Event>>	singleSplitMultiTables()
static List<List<Event>>	singleSplitSingleBatchTable()
static List<List<Event>>	singleSplitSinglePartitionTable()	A single split with a single partitioned table.
static List<List<Event>>	singleSplitSingleTable()
static List<List<Event>>	singleSplitSingleTableWithDefaultValue()
static List<List<Event>>	transformBatchTable()
static List<List<Event>>	transformTable()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TABLE_1

public static final TableId TABLE_1

TABLE_2

public static final TableId TABLE_2

Constructor Detail

ValuesDataSourceHelper

public ValuesDataSourceHelper()

Method Detail

getSourceEvents

public static List<List<Event>> getSourceEvents()

setSourceEvents

public static void setSourceEvents(List<List<Event>> customSourceEvents)

set sourceEvents using custom events.

setSourceEvents

public static void setSourceEvents(ValuesDataSourceHelper.EventSetId eventType)

set sourceEvents using predefined events.

appendOnlyBlobTable

public static List<List<Event>> appendOnlyBlobTable()

singleSplitSingleTable

public static List<List<Event>> singleSplitSingleTable()

singleSplitSingleTableWithDefaultValue

public static List<List<Event>> singleSplitSingleTableWithDefaultValue()

singleSplitSinglePartitionTable

public static List<List<Event>> singleSplitSinglePartitionTable()

A single split with a single partitioned table. The partition column is intentionally placed before data columns to verify partition handling when partition key is not at the end of the schema.

singleSplitMultiTables

public static List<List<Event>> singleSplitMultiTables()

multiSplitsSingleTable

public static List<List<Event>> multiSplitsSingleTable()

transformTable

public static List<List<Event>> transformTable()

complexColumnNameTable

public static List<List<Event>> complexColumnNameTable()

singleSplitSingleBatchTable

public static List<List<Event>> singleSplitSingleBatchTable()

singleSplitMultiBatchTable

public static List<List<Event>> singleSplitMultiBatchTable()

multiSplitSingleBatchTable

public static List<List<Event>> multiSplitSingleBatchTable()

transformBatchTable

public static List<List<Event>> transformBatchTable()