org.yamcs.yarch.rocksdb

Class RdbPartitionManager

java.lang.Object

org.yamcs.yarch.PartitionManager

org.yamcs.yarch.rocksdb.RdbPartitionManager

public class RdbPartitionManager
extends PartitionManager

Keeps track of table partitions in rocksdb storage. Types of partitions that are supported: time and time,value - creates directories of shape yyyy/ddd/tblname value - creates column families with a binary encoded version of value

Author:

nm

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(YarchDatabaseInstance ydb, TableDefinition tableDefinition)

Method Summary

Modifier and Type	Method and Description
protected Partition	createPartition(Object value) Create a partition for value based partitioning
protected Partition	createPartitionByTime(TimePartitionSchema.PartitionInfo pinfo, Object value) Create a partition for time (and possible value) based partitioning
void	readPartitionsFromDisk() Called at startup to read existing partitions from disk

Methods inherited from class org.yamcs.yarch.PartitionManager

createAndGetPartition, getPartitionForTuple, getPartitions, 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(YarchDatabaseInstance ydb,
                           TableDefinition tableDefinition)

Method Detail

readPartitionsFromDisk

public void readPartitionsFromDisk()

Called at startup to read existing partitions from disk

createPartitionByTime

protected Partition createPartitionByTime(TimePartitionSchema.PartitionInfo 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