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

Class BucketWrapperFlushEvent

java.lang.Object

org.apache.flink.cdc.common.event.FlushEvent

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

All Implemented Interfaces:

Event

public class BucketWrapperFlushEvent
extends FlushEvent

A wrapper class for FlushEvent to attach bucket id and task metadata.

Constructor Summary

Constructors

Constructor	Description
BucketWrapperFlushEvent(int bucket, int sourceSubTaskId, int bucketAssignTaskId, List<TableId> tableIds, SchemaChangeEventType schemaChangeEventType)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getBucket()
int	getBucketAssignTaskId()
int	hashCode()
String	toString()

Methods inherited from class org.apache.flink.cdc.common.event.FlushEvent

getSchemaChangeEventType, getSourceSubTaskId, getTableIds

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BucketWrapperFlushEvent

public BucketWrapperFlushEvent(int bucket,
                               int sourceSubTaskId,
                               int bucketAssignTaskId,
                               List<TableId> tableIds,
                               SchemaChangeEventType schemaChangeEventType)

Method Detail

getBucket

public int getBucket()

getBucketAssignTaskId

public int getBucketAssignTaskId()

equals

public boolean equals(Object o)

Overrides:

equals in class FlushEvent

hashCode

public int hashCode()

Overrides:

hashCode in class FlushEvent

toString

public String toString()

Overrides:

toString in class FlushEvent