Lockable (Flink : 2.0-preview1 API)

java.lang.Object
- org.apache.flink.cep.nfa.sharedbuffer.Lockable<T>

```
public final class Lockable<T>
extends Object
```
Implements locking logic for incoming event and SharedBufferNode using a lock reference counter.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class Lockable.LockableTypeSerializer<E>
Serializer for Lockable.

Constructor Summary

Constructors
Constructor Description

Lockable(T element, int refCounter)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`
`T`	`getElement()`
`int`	`hashCode()`
`void`	`lock()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Lockable

public Lockable(T element,
                int refCounter)

Method Detail
- lock
```
public void lock()
```
- getElement
```
public T getElement()
```
- toString
```
public String toString()
```
  Overrides:
  
  toString in class Object
- equals
```
public boolean equals(Object o)
```
  Overrides:
  
  equals in class Object
- hashCode
```
public int hashCode()
```
  Overrides:
  
  hashCode in class Object