Uses of Class
org.yamcs.yarch.Partition

Packages that use Partition

Package	Description
org.yamcs.yarch
org.yamcs.yarch.rocksdb

Uses of Partition in org.yamcs.yarch

Methods in org.yamcs.yarch that return Partition

Modifier and Type	Method and Description
Partition	PartitionManager.createAndGetPartition(long instant, Object value) Creates (if not already existing) and returns the partition in which the instant,value should be written.
protected abstract Partition	PartitionManager.createPartition(Object value) Create a partition for value based partitioning
protected abstract Partition	PartitionManager.createPartitionByTime(TimePartitionSchema.PartitionInfo pinfo, Object value) Create a partition for time (and possible value) based partitioning
Partition	PartitionManager.Interval.get(Object value)
Partition	PartitionManager.getPartitionForTuple(Tuple t) Gets partition where tuple has to be written.

Methods in org.yamcs.yarch that return types with arguments of type Partition

Modifier and Type	Method and Description
List<Partition>	PartitionManager.getPartitions() Retrieves the existing partitions
Map<Object,Partition>	PartitionManager.Interval.getPartitions()
Iterator<List<Partition>>	PartitionManager.iterator(long start, Set<Object> partitionValueFilter) See PartitionManager.iterator(Set)
Iterator<List<Partition>>	PartitionManager.iterator(Set<Object> partitionValueFilter) Returns an iterator which at each step gives the list of partition corresponding to a time interval (so when we do a replay those partitions have to be played in parallel).
List<Partition>	PartitionIterator.next()
Iterator<List<Partition>>	PartitionManager.reverseIterator(long start, Set<Object> partitionValueFilter)
Iterator<List<Partition>>	PartitionManager.reverseIterator(Set<Object> partitionValueFilter) same as above, only in reverse direction

Methods in org.yamcs.yarch with parameters of type Partition

Modifier and Type	Method and Description
void	PartitionManager.Interval.add(Object value, Partition partition) Add a partition
void	PartitionManager.Interval.addTimePartition(Partition partition)

Method parameters in org.yamcs.yarch with type arguments of type Partition

Modifier and Type	Method and Description
protected abstract boolean	AbstractTableReaderStream.runPartitions(List<Partition> partitions, IndexFilter range) Runs the partitions sending data only that conform with the start and end filters.

Uses of Partition in org.yamcs.yarch.rocksdb

Subclasses of Partition in org.yamcs.yarch.rocksdb

Modifier and Type	Class and Description
class	RdbPartition

Methods in org.yamcs.yarch.rocksdb that return Partition

Modifier and Type	Method and Description
protected Partition	RdbPartitionManager.createPartition(Object value)
protected Partition	RdbPartitionManager.createPartitionByTime(TimePartitionSchema.PartitionInfo pinfo, Object value)

Method parameters in org.yamcs.yarch.rocksdb with type arguments of type Partition

Modifier and Type	Method and Description
protected boolean	CfTableReaderStream.runPartitions(List<Partition> partitions, IndexFilter range) reads a file, sending data only that conform with the start and end filters.
protected boolean	InkeyTableReaderStream.runPartitions(List<Partition> partitions, IndexFilter range) reads a file, sending data only that conform with the start and end filters.