org.yamcs.yarch.rocksdb

Class YRDB

java.lang.Object

org.yamcs.yarch.rocksdb.YRDB

public class YRDB
extends Object

wrapper around RocksDB that keeps track of column families. It also maintains a reference count and last access timeused by the RdbFactory to close the database if not used for a while

Author:

nm

Method Summary

Modifier and Type	Method and Description
static String	cfNameToString(byte[] cfname)
org.rocksdb.ColumnFamilyHandle	createColumnFamily(byte[] cfname)
org.rocksdb.ColumnFamilyHandle	createColumnFamily(String name)
void	dropColumnFamily(org.rocksdb.ColumnFamilyHandle cfh)
byte[]	get(byte[] k)
byte[]	get(org.rocksdb.ColumnFamilyHandle cfh, byte[] key)
long	getApproxNumRecords()
long	getApproxNumRecords(org.rocksdb.ColumnFamilyHandle cfh)
List<byte[]>	getColumnFamilies()
Collection<String>	getColumnFamiliesAsStrings()
org.rocksdb.ColumnFamilyHandle	getColumnFamilyHandle(byte[] cfname)
org.rocksdb.ColumnFamilyHandle	getColumnFamilyHandle(String cfname)
org.rocksdb.RocksDB	getDb()
String	getPath()
String	getProperites()
boolean	isOpen()
org.rocksdb.RocksIterator	newIterator()
org.rocksdb.RocksIterator	newIterator(org.rocksdb.ColumnFamilyHandle cfh)
List<org.rocksdb.RocksIterator>	newIterators(List<org.rocksdb.ColumnFamilyHandle> cfhList, boolean tailing)
void	put(byte[] k, byte[] v)
void	put(org.rocksdb.ColumnFamilyHandle cfh, byte[] k, byte[] v)
List<byte[]>	scanPartitions(int size) scans and returns a list of all prefixes of specified size

Methods inherited from class java.lang.Object

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

Method Detail

isOpen

public boolean isOpen()

Returns:

true if the database is open

newIterators

public List<org.rocksdb.RocksIterator> newIterators(List<org.rocksdb.ColumnFamilyHandle> cfhList,
                                                    boolean tailing)
                                             throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

newIterator

public org.rocksdb.RocksIterator newIterator()
                                      throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

newIterator

public org.rocksdb.RocksIterator newIterator(org.rocksdb.ColumnFamilyHandle cfh)
                                      throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getColumnFamilyHandle

public org.rocksdb.ColumnFamilyHandle getColumnFamilyHandle(byte[] cfname)

getColumnFamilyHandle

public org.rocksdb.ColumnFamilyHandle getColumnFamilyHandle(String cfname)

get

public byte[] get(org.rocksdb.ColumnFamilyHandle cfh,
                  byte[] key)
           throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

get

public byte[] get(byte[] k)
           throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

createColumnFamily

public org.rocksdb.ColumnFamilyHandle createColumnFamily(byte[] cfname)
                                                  throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

createColumnFamily

public org.rocksdb.ColumnFamilyHandle createColumnFamily(String name)
                                                  throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

put

public void put(org.rocksdb.ColumnFamilyHandle cfh,
                byte[] k,
                byte[] v)
         throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

put

public void put(byte[] k,
                byte[] v)
         throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getColumnFamilies

public List<byte[]> getColumnFamilies()

getColumnFamiliesAsStrings

public Collection<String> getColumnFamiliesAsStrings()

getPath

public String getPath()

getProperites

public String getProperites()
                     throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

cfNameToString

public static String cfNameToString(byte[] cfname)

getDb

public org.rocksdb.RocksDB getDb()

dropColumnFamily

public void dropColumnFamily(org.rocksdb.ColumnFamilyHandle cfh)
                      throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

scanPartitions

public List<byte[]> scanPartitions(int size)
                            throws IOException

scans and returns a list of all prefixes of specified size

Parameters:

size -

Returns:

list of partitions

Throws:

IOException

getApproxNumRecords

public long getApproxNumRecords()
                         throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getApproxNumRecords

public long getApproxNumRecords(org.rocksdb.ColumnFamilyHandle cfh)
                         throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException