public class RocksDBKeySerializationUtils extends Object
Constructor and Description |
---|
RocksDBKeySerializationUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
isAmbiguousKeyPossible(TypeSerializer keySerializer,
TypeSerializer namespaceSerializer) |
static <K> K |
readKey(TypeSerializer<K> keySerializer,
ByteArrayInputStreamWithPos inputStream,
DataInputView inputView,
boolean ambiguousKeyPossible) |
static int |
readKeyGroup(int keyGroupPrefixBytes,
DataInputView inputView) |
static <N> N |
readNamespace(TypeSerializer<N> namespaceSerializer,
ByteArrayInputStreamWithPos inputStream,
DataInputView inputView,
boolean ambiguousKeyPossible) |
static <K> void |
writeKey(K key,
TypeSerializer<K> keySerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
static void |
writeKeyGroup(int keyGroup,
int keyGroupPrefixBytes,
DataOutputView keySerializationDateDataOutputView) |
static <N> void |
writeNameSpace(N namespace,
TypeSerializer<N> namespaceSerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
public static int readKeyGroup(int keyGroupPrefixBytes, DataInputView inputView) throws IOException
IOException
public static <K> K readKey(TypeSerializer<K> keySerializer, ByteArrayInputStreamWithPos inputStream, DataInputView inputView, boolean ambiguousKeyPossible) throws IOException
IOException
public static <N> N readNamespace(TypeSerializer<N> namespaceSerializer, ByteArrayInputStreamWithPos inputStream, DataInputView inputView, boolean ambiguousKeyPossible) throws IOException
IOException
public static <N> void writeNameSpace(N namespace, TypeSerializer<N> namespaceSerializer, ByteArrayOutputStreamWithPos keySerializationStream, DataOutputView 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, ByteArrayOutputStreamWithPos keySerializationStream, DataOutputView keySerializationDataOutputView, boolean ambiguousKeyPossible) throws IOException
IOException
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.