Class Lockable<T>
- java.lang.Object
-
- org.apache.flink.cep.nfa.sharedbuffer.Lockable<T>
-
public final class Lockable<T> extends Object
Implements locking logic for incoming event andSharedBufferNode
using a lock reference counter.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Lockable.LockableTypeSerializer<E>
Serializer forLockable
.
-
-
-
Constructor Detail
-
Lockable
public Lockable(T element, int refCounter)
-
-