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

Class Summary

Class	Description
BucketAssignOperator	Operator that assigns bucket indices to events and wraps them for downstream partitioning.
BucketWrapper	Wrapper class that implements Event and associates an event with a target bucket/task index.
BucketWrapperFlushEvent	A wrapper class for FlushEvent to attach bucket id and task metadata.
FlushEventAlignmentOperator	Align FlushEvents broadcasted by BucketAssignOperator.