Package org.apache.iceberg.flink.maintenance.operator

Class LockRegisterEvent

java.lang.Object

org.apache.iceberg.flink.maintenance.operator.LockRegisterEvent

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.operators.coordination.OperatorEvent

@Internal
public class LockRegisterEvent
extends Object
implements org.apache.flink.runtime.operators.coordination.OperatorEvent

Event sent from TriggerManagerOperator to TriggerManagerCoordinator to register a lock release handler. This handler will be used to forward lock release events back to the operator when triggered by downstream operators.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
LockRegisterEvent(String lockId)

Method Summary

Modifier and Type	Method	Description
String	lockId()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.operators.coordination.OperatorEvent

isLossTolerant

Constructor Details

LockRegisterEvent

public LockRegisterEvent(String lockId)

Method Details

lockId

public String lockId()

toString

public String toString()

Overrides:

toString in class Object