Uses of Class
org.apache.paimon.flink.sink.cdc.CdcSchema

Packages that use CdcSchema

Package	Description
org.apache.paimon.flink.sink.cdc

Uses of CdcSchema in org.apache.paimon.flink.sink.cdc

Fields in org.apache.paimon.flink.sink.cdc with type parameters of type CdcSchema

Modifier and Type	Field and Description
static org.apache.flink.util.OutputTag<org.apache.flink.api.java.tuple.Tuple2<Identifier,CdcSchema>>	CdcDynamicTableParsingProcessFunction.DYNAMIC_SCHEMA_CHANGE_OUTPUT_TAG
static org.apache.flink.util.OutputTag<CdcSchema>	CdcParsingProcessFunction.SCHEMA_CHANGE_OUTPUT_TAG

Methods in org.apache.paimon.flink.sink.cdc that return CdcSchema

Modifier and Type	Method and Description
CdcSchema	CdcSchema.Builder.build() Returns an instance of an unresolved CdcSchema.
CdcSchema	RichCdcRecord.cdcSchema()
CdcSchema	RichCdcMultiplexRecord.cdcSchema()
CdcSchema	RichEventParser.parseSchemaChange()
CdcSchema	RichCdcMultiplexRecordEventParser.parseSchemaChange()
CdcSchema	EventParser.parseSchemaChange() Parse new schema if this event contains schema change.

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type CdcSchema

Modifier and Type	Method and Description
static org.apache.flink.util.OutputTag<CdcSchema>	CdcMultiTableParsingProcessFunction.createSchameChangeOutputTag(String tableName)

Methods in org.apache.paimon.flink.sink.cdc with parameters of type CdcSchema

Modifier and Type	Method and Description
protected List<SchemaChange>	UpdatedDataFieldsProcessFunctionBase.extractSchemaChanges(SchemaManager schemaManager, CdcSchema updatedSchema)
void	UpdatedDataFieldsProcessFunction.processElement(CdcSchema updatedSchema, org.apache.flink.streaming.api.functions.ProcessFunction.Context context, org.apache.flink.util.Collector<Void> collector)

Method parameters in org.apache.paimon.flink.sink.cdc with type arguments of type CdcSchema

Modifier and Type	Method and Description
void	MultiTableUpdatedDataFieldsProcessFunction.processElement(org.apache.flink.api.java.tuple.Tuple2<Identifier,CdcSchema> updatedSchema, org.apache.flink.streaming.api.functions.ProcessFunction.Context context, org.apache.flink.util.Collector<Void> collector)

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type CdcSchema

Constructor and Description
RichCdcMultiplexRecord(String databaseName, String tableName, CdcSchema cdcSchema, CdcRecord cdcRecord)
RichCdcRecord(CdcRecord cdcRecord, CdcSchema cdcSchema)