org.locationtech.geowave.datastore.rocksdb.util

Class RocksDBClient

java.lang.Object

org.locationtech.geowave.datastore.rocksdb.util.RocksDBClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class RocksDBClient
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.rocksdb.WriteOptions	batchWriteOptions
protected static org.rocksdb.Options	indexWriteOptions
protected static org.rocksdb.Options	metadataOptions

Constructor Summary

Constructors

Constructor and Description
RocksDBClient(String subDirectory, boolean visibilityEnabled, boolean compactOnWrite, int batchWriteSize, boolean walOnBatchWrite)

Method Summary

Modifier and Type	Method and Description
void	close()
void	close(String indexName, String typeName)
RocksDBDataIndexTable	getDataIndexTable(String tableName, short adapterId)
List<RocksDBDataIndexTable>	getDataIndexTables(java.util.function.Predicate<RocksDBDataIndexTable> filter)
RocksDBIndexTable	getIndexTable(String tableName, short adapterId, byte[] partition, boolean requiresTimestamp)
List<RocksDBIndexTable>	getIndexTables(java.util.function.Predicate<RocksDBIndexTable> filter)
RocksDBMetadataTable	getMetadataTable(MetadataType type)
List<RocksDBMetadataTable>	getMetadataTables(java.util.function.Predicate<RocksDBMetadataTable> filter)
String	getSubDirectory()
boolean	indexTableExists(String indexName)
boolean	isCompactOnWrite()
boolean	isVisibilityEnabled()
void	mergeData()
void	mergeMetadata()
boolean	metadataTableExists(MetadataType type)

Methods inherited from class java.lang.Object

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

Field Detail

indexWriteOptions

protected static org.rocksdb.Options indexWriteOptions

batchWriteOptions

protected org.rocksdb.WriteOptions batchWriteOptions

metadataOptions

protected static org.rocksdb.Options metadataOptions

Constructor Detail

RocksDBClient

public RocksDBClient(String subDirectory,
                     boolean visibilityEnabled,
                     boolean compactOnWrite,
                     int batchWriteSize,
                     boolean walOnBatchWrite)

Method Detail

getSubDirectory

public String getSubDirectory()

getIndexTable

public RocksDBIndexTable getIndexTable(String tableName,
                                       short adapterId,
                                       byte[] partition,
                                       boolean requiresTimestamp)

getDataIndexTable

public RocksDBDataIndexTable getDataIndexTable(String tableName,
                                               short adapterId)

getMetadataTable

public RocksDBMetadataTable getMetadataTable(MetadataType type)

indexTableExists

public boolean indexTableExists(String indexName)

metadataTableExists

public boolean metadataTableExists(MetadataType type)

close

public void close(String indexName,
                  String typeName)

isCompactOnWrite

public boolean isCompactOnWrite()

isVisibilityEnabled

public boolean isVisibilityEnabled()

getIndexTables

public List<RocksDBIndexTable> getIndexTables(java.util.function.Predicate<RocksDBIndexTable> filter)

getDataIndexTables

public List<RocksDBDataIndexTable> getDataIndexTables(java.util.function.Predicate<RocksDBDataIndexTable> filter)

getMetadataTables

public List<RocksDBMetadataTable> getMetadataTables(java.util.function.Predicate<RocksDBMetadataTable> filter)

mergeData

public void mergeData()

mergeMetadata

public void mergeMetadata()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable