Package org.apache.flink.cdc.connectors.hudi.sink.event

Interface Summary

Interface	Description
HudiRecordSerializer<T>	A serializer interface for converting input records into HoodieFlinkInternalRow for Hudi writing.

Class Summary

Class	Description
EnhancedWriteMetadataEvent	An OperatorEvent that enhances a standard Hudi WriteMetadataEvent with additional context required for multi-table sinking.
HudiRecordEventSerializer	A HudiRecordSerializer for converting Event into HoodieFlinkInternalRow for Hudi writing.
SchemaChangeOperatorEvent	An operator event that encapsulates a schema change and the resulting new schema.
TableAwareCorrespondent	A correspondent between a write task and the multi-table coordinator.
TableAwareCorrespondent.CreateTableRequest	A CoordinationRequest that encapsulates a CreateTableEvent.
TableAwareCorrespondent.MultiTableInstantTimeRequest	A custom coordination request that includes the TableId to request an instant for a specific table.
TableAwareCorrespondent.SchemaChangeRequest	A CoordinationRequest that represents a request to change table schema.
TableAwareCorrespondent.SchemaChangeResponse	Response for a TableAwareCorrespondent.CreateTableRequest or TableAwareCorrespondent.SchemaChangeRequest.