public class RocksDBKeySerializationUtils extends Object
Constructor and Description |
---|
RocksDBKeySerializationUtils() |
Modifier and Type | Method and Description |
---|---|
static int |
computeRequiredBytesInKeyGroupPrefix(int totalKeyGroupsInJob) |
static boolean |
isAmbiguousKeyPossible(TypeSerializer keySerializer,
TypeSerializer namespaceSerializer) |
static <K> K |
readKey(TypeSerializer<K> keySerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
static <N> N |
readNamespace(TypeSerializer<N> namespaceSerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
static void |
serializeKeyGroup(int keyGroup,
byte[] startKeyGroupPrefixBytes) |
static <K> void |
writeKey(K key,
TypeSerializer<K> keySerializer,
DataOutputSerializer keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
static void |
writeKeyGroup(int keyGroup,
int keyGroupPrefixBytes,
DataOutputView keySerializationDateDataOutputView) |
static <N> void |
writeNameSpace(N namespace,
TypeSerializer<N> namespaceSerializer,
DataOutputSerializer keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
public static <K> K readKey(TypeSerializer<K> keySerializer, DataInputDeserializer inputView, boolean ambiguousKeyPossible) throws IOException
IOException
public static <N> N readNamespace(TypeSerializer<N> namespaceSerializer, DataInputDeserializer inputView, boolean ambiguousKeyPossible) throws IOException
IOException
public static <N> void writeNameSpace(N namespace, TypeSerializer<N> namespaceSerializer, DataOutputSerializer keySerializationDataOutputView, boolean ambiguousKeyPossible) throws IOException
IOException
public static boolean isAmbiguousKeyPossible(TypeSerializer keySerializer, TypeSerializer namespaceSerializer)
public static void writeKeyGroup(int keyGroup, int keyGroupPrefixBytes, DataOutputView keySerializationDateDataOutputView) throws IOException
IOException
public static <K> void writeKey(K key, TypeSerializer<K> keySerializer, DataOutputSerializer keySerializationDataOutputView, boolean ambiguousKeyPossible) throws IOException
IOException
public static void serializeKeyGroup(int keyGroup, byte[] startKeyGroupPrefixBytes)
public static int computeRequiredBytesInKeyGroupPrefix(int totalKeyGroupsInJob)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.