alluxio.master.metastore.rocks

Class RocksStore

java.lang.Object

alluxio.master.metastore.rocks.RocksStore

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class RocksStore
extends java.lang.Object
implements java.io.Closeable

Class for managing a rocksdb database. This class handles common functionality such as initializing the database and performing database backup/restore. Thread safety is achieved by synchronizing all public methods.

Constructor Summary

Constructors

Constructor and Description
RocksStore(java.lang.String dbPath, java.lang.String checkpointPath, java.util.Collection<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptors, org.rocksdb.DBOptions dbOpts, java.util.List<java.util.concurrent.atomic.AtomicReference<org.rocksdb.ColumnFamilyHandle>> columnHandles)

Method Summary

Modifier and Type	Method and Description
void	clear() Clears and re-initializes the database.
void	close()
org.rocksdb.RocksDB	getDb()
void	restoreFromCheckpoint(CheckpointInputStream input) Restores the database from a checkpoint.
void	writeToCheckpoint(java.io.OutputStream output) Writes a checkpoint of the database's content to the given output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksStore

public RocksStore(java.lang.String dbPath,
                  java.lang.String checkpointPath,
                  java.util.Collection<org.rocksdb.ColumnFamilyDescriptor> columnFamilyDescriptors,
                  org.rocksdb.DBOptions dbOpts,
                  java.util.List<java.util.concurrent.atomic.AtomicReference<org.rocksdb.ColumnFamilyHandle>> columnHandles)

Parameters:

dbPath - a path for the rocks database

checkpointPath - a path for taking database checkpoints

columnFamilyDescriptors - columns to create within the rocks database

dbOpts - db options

columnHandles - column handle references to populate

Method Detail

getDb

public org.rocksdb.RocksDB getDb()

Returns:

the underlying rocksdb instance. The instance changes when clear() is called, so if the caller caches the returned db, they must reset it after calling clear()

clear

public void clear()

Clears and re-initializes the database.

writeToCheckpoint

public void writeToCheckpoint(java.io.OutputStream output)
                       throws java.io.IOException,
                              java.lang.InterruptedException

Writes a checkpoint of the database's content to the given output stream.

Parameters:

output - the stream to write to

Throws:

java.io.IOException

java.lang.InterruptedException

restoreFromCheckpoint

public void restoreFromCheckpoint(CheckpointInputStream input)
                           throws java.io.IOException

Restores the database from a checkpoint.

Parameters:

input - the checkpoint stream to restore from

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable