public interface WriteBuffer
Modifier and Type | Interface and Description |
---|---|
static interface |
WriteBuffer.KvConsumer
A Consumer that accepts KeyValue and throw exceptions.
|
Modifier and Type | Method and Description |
---|---|
void |
clear()
Removes all records from this table.
|
boolean |
flushMemory()
Flush memory, return false if not supported.
|
void |
forEach(Comparator<org.apache.flink.table.data.RowData> keyComparator,
MergeFunction<KeyValue> mergeFunction,
WriteBuffer.KvConsumer rawConsumer,
WriteBuffer.KvConsumer mergedConsumer)
Performs the given action for each remaining element in this buffer until all elements have
been processed or the action throws an exception.
|
long |
memoryOccupancy()
Memory occupancy size of this table.
|
boolean |
put(long sequenceNumber,
org.apache.flink.types.RowKind valueKind,
org.apache.flink.table.data.RowData key,
org.apache.flink.table.data.RowData value)
Put a record with sequence number and value kind.
|
int |
size()
Record size of this table.
|
boolean put(long sequenceNumber, org.apache.flink.types.RowKind valueKind, org.apache.flink.table.data.RowData key, org.apache.flink.table.data.RowData value) throws IOException
IOException
int size()
long memoryOccupancy()
boolean flushMemory() throws IOException
IOException
void forEach(Comparator<org.apache.flink.table.data.RowData> keyComparator, MergeFunction<KeyValue> mergeFunction, @Nullable WriteBuffer.KvConsumer rawConsumer, WriteBuffer.KvConsumer mergedConsumer) throws IOException
rawConsumer
- consumer to consume records without merging.mergedConsumer
- consumer to consume records after merging.IOException
void clear()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.