org.yamcs.yarch.rocksdb

Class RdbPartitionManager

java.lang.Object

org.yamcs.yarch.PartitionManager

org.yamcs.yarch.rocksdb.RdbPartitionManager

public class RdbPartitionManager
extends PartitionManager

Handles partitions for one table. All partitions are stored as records in the tablespace.

Nested Class Summary

Nested classes/interfaces inherited from class org.yamcs.yarch.PartitionManager

PartitionManager.Interval

Field Summary

Fields inherited from class org.yamcs.yarch.PartitionManager

intervals, partitioningSpec, pcache, tableDefinition

Constructor Summary

Constructors

Constructor and Description
RdbPartitionManager(Tablespace tablespace, YarchDatabaseInstance ydb, TableDefinition tableDefinition)

Method Summary

Modifier and Type	Method and Description
protected HistogramInfo	createHistogram(String columnName)
protected HistogramInfo	createHistogramByTime(TimePartitionInfo pinfo, String columnName)
protected Partition	createPartition(Object value) Create a partition for value based partitioning
protected Partition	createPartitionByTime(TimePartitionInfo pinfo, Object value) Create a partition for time (and possible value) based partitioning
void	readPartitions() Called at startup to read existing partitions

Methods inherited from class org.yamcs.yarch.PartitionManager

createAndGetHistogram, createAndGetPartition, getPartitionForTuple, getPartitions, intervalIterator, iterator, iterator, reverseIterator, reverseIterator

Methods inherited from class java.lang.Object

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

Constructor Detail

RdbPartitionManager

public RdbPartitionManager(Tablespace tablespace,
                           YarchDatabaseInstance ydb,
                           TableDefinition tableDefinition)

Method Detail

readPartitions

public void readPartitions()
                    throws org.rocksdb.RocksDBException,
                           IOException

Called at startup to read existing partitions

Throws:

IOException

org.rocksdb.RocksDBException

createPartitionByTime

protected Partition createPartitionByTime(TimePartitionInfo pinfo,
                                          Object value)
                                   throws IOException

Description copied from class: PartitionManager

Create a partition for time (and possible value) based partitioning

Specified by:

createPartitionByTime in class PartitionManager

Returns:

Throws:

IOException

createPartition

protected Partition createPartition(Object value)
                             throws IOException

Description copied from class: PartitionManager

Create a partition for value based partitioning

Specified by:

createPartition in class PartitionManager

Returns:

Throws:

IOException

createHistogramByTime

protected HistogramInfo createHistogramByTime(TimePartitionInfo pinfo,
                                              String columnName)
                                       throws IOException

Specified by:

createHistogramByTime in class PartitionManager

Throws:

IOException

createHistogram

protected HistogramInfo createHistogram(String columnName)
                                 throws IOException

Specified by:

createHistogram in class PartitionManager

Throws:

IOException