Uses of Class
org.apache.flink.cdc.common.event.CreateTableEvent

Packages that use CreateTableEvent

Package	Description
org.apache.flink.cdc.connectors.hudi.sink.event
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.serializer.event

Uses of CreateTableEvent in org.apache.flink.cdc.connectors.hudi.sink.event

Methods in org.apache.flink.cdc.connectors.hudi.sink.event with parameters of type CreateTableEvent

Modifier and Type	Method	Description
boolean	TableAwareCorrespondent.requestCreatingTable(CreateTableEvent createTableEvent)	Send a request to coordinator to create a hudi table.

Constructors in org.apache.flink.cdc.connectors.hudi.sink.event with parameters of type CreateTableEvent

Constructor	Description
CreateTableRequest(CreateTableEvent createTableEvent)

Uses of CreateTableEvent in org.apache.flink.cdc.debezium.event

Methods in org.apache.flink.cdc.debezium.event that return types with arguments of type CreateTableEvent

Modifier and Type	Method	Description
Map<io.debezium.relational.TableId,CreateTableEvent>	DebeziumEventDeserializationSchema.getCreateTableEventCache()

Uses of CreateTableEvent in org.apache.flink.cdc.runtime.operators.schema.common

Methods in org.apache.flink.cdc.runtime.operators.schema.common that return types with arguments of type CreateTableEvent

Modifier and Type	Method	Description
static List<CreateTableEvent>	SchemaDerivator.deduceMergedCreateTableEvent(TableIdRouter router, List<CreateTableEvent> createTableEvents)	Deduce merged CreateTableEvent.

Methods in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type CreateTableEvent

Modifier and Type	Method	Description
boolean	ExistingTableSchemaExpander.handleExistingTableCreation(CreateTableEvent createTableEvent)	Handles the initial CreateTableEvent for an existing target table.

Method parameters in org.apache.flink.cdc.runtime.operators.schema.common with type arguments of type CreateTableEvent

Modifier and Type	Method	Description
static List<CreateTableEvent>	SchemaDerivator.deduceMergedCreateTableEvent(TableIdRouter router, List<CreateTableEvent> createTableEvents)	Deduce merged CreateTableEvent.

Uses of CreateTableEvent in org.apache.flink.cdc.runtime.operators.transform

Methods in org.apache.flink.cdc.runtime.operators.transform that return CreateTableEvent

Modifier and Type	Method	Description
CreateTableEvent	PreTransformProcessor.preTransformCreateTableEvent(CreateTableEvent createTableEvent)	This method analyses (directly and indirectly) referenced columns, and peels unused columns from schema.

Methods in org.apache.flink.cdc.runtime.operators.transform with parameters of type CreateTableEvent

Modifier and Type	Method	Description
CreateTableEvent	PreTransformProcessor.preTransformCreateTableEvent(CreateTableEvent createTableEvent)	This method analyses (directly and indirectly) referenced columns, and peels unused columns from schema.

Uses of CreateTableEvent in org.apache.flink.cdc.runtime.serializer.event

Methods in org.apache.flink.cdc.runtime.serializer.event that return CreateTableEvent

Modifier and Type	Method	Description
CreateTableEvent	CreateTableEventSerializer.copy(CreateTableEvent from)
CreateTableEvent	CreateTableEventSerializer.copy(CreateTableEvent from, CreateTableEvent reuse)
CreateTableEvent	CreateTableEventSerializer.createInstance()
CreateTableEvent	CreateTableEventSerializer.deserialize(CreateTableEvent reuse, org.apache.flink.core.memory.DataInputView source)
CreateTableEvent	CreateTableEventSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.flink.cdc.runtime.serializer.event that return types with arguments of type CreateTableEvent

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<CreateTableEvent>	CreateTableEventSerializer.snapshotConfiguration()

Methods in org.apache.flink.cdc.runtime.serializer.event with parameters of type CreateTableEvent

Modifier and Type	Method	Description
CreateTableEvent	CreateTableEventSerializer.copy(CreateTableEvent from)
CreateTableEvent	CreateTableEventSerializer.copy(CreateTableEvent from, CreateTableEvent reuse)
CreateTableEvent	CreateTableEventSerializer.deserialize(CreateTableEvent reuse, org.apache.flink.core.memory.DataInputView source)
void	CreateTableEventSerializer.serialize(CreateTableEvent record, org.apache.flink.core.memory.DataOutputView target)