public static class LookupLevels.PositionedKeyValueProcessor extends Object implements LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>
Constructor and Description |
---|
PositionedKeyValueProcessor(RowType valueType,
boolean persistValue) |
Modifier and Type | Method and Description |
---|---|
byte[] |
persistToDisk(KeyValue kv) |
byte[] |
persistToDisk(KeyValue kv,
long rowPosition) |
LookupLevels.PositionedKeyValue |
readFromDisk(InternalRow key,
int level,
byte[] bytes,
String fileName) |
boolean |
withPosition() |
public PositionedKeyValueProcessor(RowType valueType, boolean persistValue)
public boolean withPosition()
withPosition
in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>
public byte[] persistToDisk(KeyValue kv)
persistToDisk
in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>
public byte[] persistToDisk(KeyValue kv, long rowPosition)
persistToDisk
in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>
public LookupLevels.PositionedKeyValue readFromDisk(InternalRow key, int level, byte[] bytes, String fileName)
readFromDisk
in interface LookupLevels.ValueProcessor<LookupLevels.PositionedKeyValue>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.