public static class LookupLevels.KeyValueProcessor extends Object implements LookupLevels.ValueProcessor<KeyValue>
LookupLevels.ValueProcessor
to return KeyValue
.Constructor and Description |
---|
KeyValueProcessor(RowType valueType) |
Modifier and Type | Method and Description |
---|---|
byte[] |
persistToDisk(KeyValue kv) |
KeyValue |
readFromDisk(InternalRow key,
int level,
byte[] bytes,
String fileName) |
boolean |
withPosition() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
persistToDisk
public KeyValueProcessor(RowType valueType)
public boolean withPosition()
withPosition
in interface LookupLevels.ValueProcessor<KeyValue>
public byte[] persistToDisk(KeyValue kv)
persistToDisk
in interface LookupLevels.ValueProcessor<KeyValue>
public KeyValue readFromDisk(InternalRow key, int level, byte[] bytes, String fileName)
readFromDisk
in interface LookupLevels.ValueProcessor<KeyValue>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.