alluxio.master.metastore.rocks

Class RocksUtils

java.lang.Object

alluxio.master.metastore.rocks.RocksUtils

public final class RocksUtils
extends Object

Convenience methods for working with RocksDB.

Method Summary

Modifier and Type	Method and Description
static <T> Iterator<T>	createIterator(org.rocksdb.RocksIterator rocksIterator, alluxio.master.metastore.rocks.RocksUtils.RocksIteratorParser<T> parser) Used to wrap an Iterator over RocksIterator.
static String	generateDbPath(String baseDir, String dbName) Generates a path to use for a RocksDB database.
static long	readLong(byte[] bytes, int start)
static byte[]	toByteArray(long long1, long long2)
static byte[]	toByteArray(long n, String str)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

generateDbPath

public static String generateDbPath(String baseDir,
                                    String dbName)

Generates a path to use for a RocksDB database.

Parameters:

baseDir - the base directory path

dbName - a name for the database

Returns:

the generated database path

toByteArray

public static byte[] toByteArray(long long1,
                                 long long2)

Parameters:

long1 - a long value

long2 - a long value

Returns:

a byte array formed by writing the two long values as bytes

toByteArray

public static byte[] toByteArray(long n,
                                 String str)

Parameters:

n - a long value

str - a string value

Returns:

a byte array formed by writing the bytes of n followed by the bytes of str

readLong

public static long readLong(byte[] bytes,
                            int start)

Parameters:

bytes - an array of bytes

start - the place in the array to read the long from

Returns:

the long

createIterator

public static <T> Iterator<T> createIterator(org.rocksdb.RocksIterator rocksIterator,
                                             alluxio.master.metastore.rocks.RocksUtils.RocksIteratorParser<T> parser)

Used to wrap an Iterator over RocksIterator. It seeks given iterator to first entry before returning the iterator.

Type Parameters:

T - iterator value type

Parameters:

rocksIterator - the rocks iterator

parser - parser to produce iterated values from rocks key-value

Returns:

wrapped iterator