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

Packages that use FlushEvent

Package	Description
org.apache.flink.cdc.connectors.hudi.sink.bucket
org.apache.flink.cdc.connectors.hudi.sink.function
org.apache.flink.cdc.connectors.paimon.sink.v2.bucket

Uses of FlushEvent in org.apache.flink.cdc.connectors.hudi.sink.bucket

Subclasses of FlushEvent in org.apache.flink.cdc.connectors.hudi.sink.bucket

Modifier and Type	Class	Description
class	BucketWrapperFlushEvent	A wrapper class for FlushEvent to attach bucket id and task metadata.

Uses of FlushEvent in org.apache.flink.cdc.connectors.hudi.sink.function

Methods in org.apache.flink.cdc.connectors.hudi.sink.function with parameters of type FlushEvent

Modifier and Type	Method	Description
void	EventProcessorFunction.processFlush(FlushEvent event)	Process flush events for coordinated flushing.
void	MultiTableEventStreamWriteFunction.processFlush(FlushEvent event)	Processes flush events for coordinated flushing across table functions.

Uses of FlushEvent in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket

Subclasses of FlushEvent in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket

Modifier and Type	Class	Description
class	BucketWrapperFlushEvent	A wrapper class for FlushEvent to attach bucket id.