Package | Description |
---|---|
org.locationtech.geowave.datastore.rocksdb.operations | |
org.locationtech.geowave.datastore.rocksdb.util |
Modifier and Type | Method and Description |
---|---|
RocksDBClient |
RocksDBOperations.getClient() |
Constructor and Description |
---|
RockDBDataIndexWriter(RocksDBClient client,
short adapterId,
String typeName) |
RocksDBQueryExecution(RocksDBClient client,
String indexNamePrefix,
short adapterId,
GeoWaveRowIteratorTransformer<T> rowTransformer,
Collection<SinglePartitionQueryRanges> ranges,
java.util.function.Predicate<GeoWaveRow> filter,
boolean rowMerging,
boolean async,
org.apache.commons.lang3.tuple.Pair<Boolean,Boolean> groupByRowAndSortByTimePair,
boolean isSortFinalResultsBySortKey) |
RocksDBReader(RocksDBClient client,
DataIndexReaderParams dataIndexReaderParams) |
RocksDBReader(RocksDBClient client,
ReaderParams<T> readerParams,
boolean async) |
RocksDBReader(RocksDBClient client,
RecordReaderParams recordReaderParams) |
RocksDBRowDeleter(RocksDBClient client,
PersistentAdapterStore adapterStore,
InternalAdapterStore internalAdapterStore,
String indexName) |
RocksDBWriter(RocksDBClient client,
short adapterId,
String typeName,
String indexName,
boolean isTimestampRequired) |
Modifier and Type | Method and Description |
---|---|
RocksDBClient |
RocksDBClientCache.getClient(String directory,
boolean visibilityEnabled,
boolean compactOnWrite,
int batchWriteSize,
boolean walOnBatchWrite) |
Modifier and Type | Method and Description |
---|---|
static RocksDBDataIndexTable |
RocksDBUtils.getDataIndexTable(RocksDBClient client,
String typeName,
short adapterId) |
static RocksDBIndexTable |
RocksDBUtils.getIndexTable(RocksDBClient client,
String tableName,
short adapterId,
byte[] partitionKey,
boolean requiresTimestamp) |
static RocksDBIndexTable |
RocksDBUtils.getIndexTable(RocksDBClient client,
String typeName,
String indexName,
short adapterId,
byte[] partitionKey,
boolean requiresTimestamp) |
static RocksDBIndexTable |
RocksDBUtils.getIndexTableFromPrefix(RocksDBClient client,
String namePrefix,
short adapterId,
byte[] partitionKey,
boolean requiresTimestamp) |
static RocksDBMetadataTable |
RocksDBUtils.getMetadataTable(RocksDBClient client,
MetadataType metadataType) |
Copyright © 2013–2022. All rights reserved.