public interface NormalizedKeyComputer
SortBuffer
. For performance, subclasses are usually
implemented through CodeGenerator. Copied from Flink.Modifier and Type | Method and Description |
---|---|
int |
compareKey(org.apache.flink.core.memory.MemorySegment segI,
int offsetI,
org.apache.flink.core.memory.MemorySegment segJ,
int offsetJ)
Compares two normalized keys in respective
MemorySegment . |
int |
getNumKeyBytes()
Get normalized keys bytes length.
|
boolean |
invertKey()
Flag whether normalized key comparisons should be inverted key.
|
boolean |
isKeyFullyDetermines()
whether the normalized key can fully determines the comparison.
|
void |
putKey(org.apache.flink.table.data.RowData record,
org.apache.flink.core.memory.MemorySegment target,
int offset)
Writes a normalized key for the given record into the target
MemorySegment . |
void |
swapKey(org.apache.flink.core.memory.MemorySegment segI,
int offsetI,
org.apache.flink.core.memory.MemorySegment segJ,
int offsetJ)
Swaps two normalized keys in respective
MemorySegment . |
void putKey(org.apache.flink.table.data.RowData record, org.apache.flink.core.memory.MemorySegment target, int offset)
MemorySegment
.int compareKey(org.apache.flink.core.memory.MemorySegment segI, int offsetI, org.apache.flink.core.memory.MemorySegment segJ, int offsetJ)
MemorySegment
.void swapKey(org.apache.flink.core.memory.MemorySegment segI, int offsetI, org.apache.flink.core.memory.MemorySegment segJ, int offsetJ)
MemorySegment
.int getNumKeyBytes()
boolean isKeyFullyDetermines()
boolean invertKey()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.