Modifier and Type | Method and Description |
---|---|
void |
LocalAggCombiner.combine(WindowKey windowKey,
Iterator<RowData> records) |
void |
AggCombiner.combine(WindowKey windowKey,
Iterator<RowData> records) |
void |
GlobalAggCombiner.combine(WindowKey windowKey,
Iterator<RowData> localAccs) |
Modifier and Type | Method and Description |
---|---|
void |
RowTimeDeduplicateRecordsCombiner.combine(WindowKey windowKey,
Iterator<RowData> records) |
Modifier and Type | Method and Description |
---|---|
void |
TopNRecordsCombiner.combine(WindowKey windowKey,
Iterator<RowData> records) |
Modifier and Type | Method and Description |
---|---|
void |
RecordsCombiner.combine(WindowKey windowKey,
Iterator<RowData> records)
Combines the buffered data into state based on the given window-key pair.
|
Modifier and Type | Method and Description |
---|---|
WindowKey |
WindowKeySerializer.copy(WindowKey from) |
WindowKey |
WindowKeySerializer.copy(WindowKey from,
WindowKey reuse) |
WindowKey |
WindowKeySerializer.createInstance() |
WindowKey |
WindowKeySerializer.deserialize(DataInputView source) |
WindowKey |
WindowKeySerializer.deserialize(WindowKey reuse,
DataInputView source) |
WindowKey |
WindowKeySerializer.deserializeFromPages(AbstractPagedInputView source) |
WindowKey |
WindowKeySerializer.deserializeFromPages(WindowKey reuse,
AbstractPagedInputView source) |
WindowKey |
WindowKeySerializer.mapFromPages(WindowKey reuse,
AbstractPagedInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<WindowKey> |
WindowKeySerializer.duplicate() |
TypeSerializerSnapshot<WindowKey> |
WindowKeySerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
WindowKey |
WindowKeySerializer.copy(WindowKey from) |
WindowKey |
WindowKeySerializer.copy(WindowKey from,
WindowKey reuse) |
WindowKey |
WindowKeySerializer.deserialize(WindowKey reuse,
DataInputView source) |
WindowKey |
WindowKeySerializer.deserializeFromPages(WindowKey reuse,
AbstractPagedInputView source) |
WindowKey |
WindowKeySerializer.mapFromPages(WindowKey reuse,
AbstractPagedInputView source) |
void |
WindowKeySerializer.serialize(WindowKey record,
DataOutputView target) |
int |
WindowKeySerializer.serializeToPages(WindowKey record,
AbstractPagedOutputView target)
Actually, the return value is just for saving checkSkipReadForFixLengthPart in the
mapFromPages, the cost is very small.
|
Modifier and Type | Method and Description |
---|---|
WindowKey |
WindowKey.replace(long window,
RowData key)
Replace the currently stored key and window by the given new key and new window.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.