java.lang.Object
- org.apache.flink.table.runtime.operators.join.lookup.keyordered.RecordsBuffer<ELEMENT,KEY>

```
public class RecordsBuffer<ELEMENT,KEY>
extends Object
```
The RecordsBuffer is used to store the element that need to be processed in TableAsyncExecutionController.

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`void`	`enqueueRecord(KEY key, ELEMENT record)`
`void`	`finish(KEY key, ELEMENT element)`
`Map<KEY,ELEMENT>`	`getActiveBuffer()`
`int`	`getActiveSize()`
`Map<KEY,Deque<ELEMENT>>`	`getBlockingBuffer()`
`int`	`getBlockingSize()`
`Map<KEY,Deque<ELEMENT>>`	`getFinishedBuffer()`
`int`	`getFinishSize()`
`void`	`output(KEY key, ELEMENT element)`
`Map<KEY,Deque<ELEMENT>>`	`pendingElements()`	Collect all elements which are not emitted for snapshot.
`Optional<ELEMENT>`	`pop(KEY key)`
`String`	`sizeToString()`

public void enqueueRecord(KEY key,
                          ELEMENT record)

public Optional<ELEMENT> pop(KEY key)

public void finish(KEY key,
                   ELEMENT element)

public void output(KEY key,
                   ELEMENT element)

pendingElements
```
public Map<KEY,Deque<ELEMENT>> pendingElements()
```
Collect all elements which are not emitted for snapshot.

@VisibleForTesting
public Map<KEY,Deque<ELEMENT>> getFinishedBuffer()

@VisibleForTesting
public Map<KEY,ELEMENT> getActiveBuffer()

@VisibleForTesting
public Map<KEY,Deque<ELEMENT>> getBlockingBuffer()

Class RecordsBuffer<ELEMENT,​KEY>

Class RecordsBuffer<ELEMENT,KEY>