public class RocksDBDataStore extends BaseMapReduceDataStore implements Closeable
BaseDataStore.DeletionMode
splitsProvider
adapterStore, baseOperations, baseOptions, indexMappingStore, indexStore, internalAdapterStore, propertyStore, statisticsStore
Constructor and Description |
---|
RocksDBDataStore(RocksDBOperations operations,
DataStoreOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
close()
This is not a typical resource, it references a static RocksDB resource used by all DataStore
instances with common parameters.
|
boolean |
isReverseIterationSupported() |
createRecordReader, createRecordWriter, createSplitsProvider, getSplits, prepareRecordWriter
addEmptyStatistic, addIndex, addIndex, addStatistic, addType, addType, addType, addTypeInternal, aggregate, aggregateStatistics, copyTo, copyTo, createDataIndexWriter, createIndexWriter, createWriter, createWriter, delete, delete, delete, delete, deleteAll, deleteEverything, deleteFromDataIndex, getAdapterId, getAdapterStore, getBaseOperations, getBinnedStatisticValues, getDataTypeStatistic, getDataTypeStatistics, getFieldStatistic, getFieldStatistics, getIndex, getIndexMappingStore, getIndexStatistic, getIndexStatistics, getIndexStore, getIndices, getIndices, getInternalAdapterStore, getStatisticsStore, getStatisticValue, getType, getTypes, ingest, ingest, initOnIndexWriterCreate, internalQuery, internalQuery, internalQuery, internalQueryStatistics, query, query, query, queryConstraints, queryInsertionId, queryRowPrefix, queryStatistics, recalcStatistic, removeIndex, removeIndex, removeStatistic, removeType, store, store
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addEmptyStatistic, addIndex, addIndex, addStatistic, addType, addType, addType, aggregate, aggregateStatistics, copyTo, copyTo, createWriter, createWriter, delete, deleteAll, getBinnedStatisticValues, getBinnedStatisticValues, getDataTypeStatistic, getDataTypeStatistics, getFieldStatistic, getFieldStatistics, getIndex, getIndexStatistic, getIndexStatistics, getIndices, getIndices, getStatisticValue, getStatisticValue, getType, getTypes, ingest, ingest, query, query, queryStatistics, recalcStatistic, removeIndex, removeIndex, removeStatistic, removeType
public RocksDBDataStore(RocksDBOperations operations, DataStoreOptions options)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public boolean isReverseIterationSupported()
isReverseIterationSupported
in class BaseDataStore
Copyright © 2013–2022. All rights reserved.