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

Class ValuesDatabase

java.lang.Object

org.apache.flink.cdc.connectors.values.ValuesDatabase

@Internal
public class ValuesDatabase
extends Object

An auxiliary class for simulating a database, use for ValuesDataSource and ValuesDataSink.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ValuesDatabase.ErrorOnChangeMetadataApplier	apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.
static class	ValuesDatabase.ValuesMetadataAccessor	provide namespace/schema/table lists for ValuesDataSource.
static class	ValuesDatabase.ValuesMetadataApplier	apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.

Constructor Summary

Constructors

Constructor	Description
ValuesDatabase()

Method Summary

Modifier and Type	Method	Description
static void	applyDataChangeEvent(DataChangeEvent event)
static void	applySchemaChangeEvent(SchemaChangeEvent event)
static void	applyTruncateTableEvent(TruncateTableEvent event)
static void	clear()
static List<String>	getAllResults()
static List<String>	getResults(TableId tableId)
static Schema	getTableSchema(TableId tableId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ValuesDatabase

public ValuesDatabase()

Method Detail

getTableSchema

public static Schema getTableSchema(TableId tableId)

applyTruncateTableEvent

public static void applyTruncateTableEvent(TruncateTableEvent event)

applyDataChangeEvent

public static void applyDataChangeEvent(DataChangeEvent event)

applySchemaChangeEvent

public static void applySchemaChangeEvent(SchemaChangeEvent event)

getAllResults

public static List<String> getAllResults()

getResults

public static List<String> getResults(TableId tableId)

clear

public static void clear()