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

Interface Summary

Interface	Description
EventProcessorFunction	Template interface for processing CDC events in a standardized way.

Class Summary

Class	Description
ExtendedBucketStreamWriteFunction	Extended version of BucketStreamWriteFunction that exposes a public setter for the checkpoint ID.
MultiTableEventStreamWriteFunction	Multi-table wrapper function that routes events to table-specific EventExtendedBucketStreamWriteFunction instances.