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

Class LockReleaseEvent

java.lang.Object

org.apache.iceberg.flink.maintenance.operator.LockReleaseEvent

All Implemented Interfaces:

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

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

Event sent from LockRemoverOperator to LockRemoverCoordinator to notify that a lock has been released. The LockRemoverCoordinator then forwards this event to the TriggerManagerOperator via the registered lock release handler.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
LockReleaseEvent(String lockId, long timestamp)

Method Summary

Modifier and Type	Method	Description
String	lockId()
long	timestamp()
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

LockReleaseEvent

public LockReleaseEvent(String lockId,
 long timestamp)

Method Details

timestamp

public long timestamp()

lockId

public String lockId()

toString

public String toString()

Overrides:

toString in class Object