org.yamcs.parameterarchive

Class ParameterArchiveV2

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.parameterarchive.ParameterArchiveV2

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class ParameterArchiveV2
extends com.google.common.util.concurrent.AbstractService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ParameterArchiveV2.Partition

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	STORE_RAW_VALUES

Constructor Summary

Constructors

Constructor and Description
ParameterArchiveV2(String instance)
ParameterArchiveV2(String instance, Map<String,Object> args)

Method Summary

Modifier and Type	Method and Description
ParameterArchiveV2.Partition	createAndGetPartition(long segStart) get partition for segment, creating it if it doesn't exist
List<ParameterArchiveV2.Partition>	deletePartitions(long start, long stop) Delete all partitions that overlap with [start, stop) segment.
protected void	doStart()
protected void	doStop()
org.rocksdb.RocksIterator	getIterator(ParameterArchiveV2.Partition p)
ParameterGroupIdDb	getParameterGroupIdDb()
ParameterIdDb	getParameterIdDb()
TimePartitionSchema	getPartitioningSchema()
List<ParameterArchiveV2.Partition>	getPartitions(long start, long stop, boolean ascending) a copy of the partitions from start to stop inclusive
Tablespace	getTablespace()
SortedTimeSegment	getTimeSegment(ParameterArchiveV2.Partition p, long segmentStart, int parameterGroupId)
String	getYamcsInstance()
void	printKeys(PrintStream out)
Future<?>	reprocess(long start, long stop)
void	writeToArchive(long segStart, Collection<PGSegment> pgList)
void	writeToArchive(PGSegment pgs)

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Field Detail

STORE_RAW_VALUES

public static final boolean STORE_RAW_VALUES

See Also:

Constant Field Values

Constructor Detail

ParameterArchiveV2

public ParameterArchiveV2(String instance,
                          Map<String,Object> args)
                   throws IOException,
                          org.rocksdb.RocksDBException

Throws:

IOException

org.rocksdb.RocksDBException

ParameterArchiveV2

public ParameterArchiveV2(String instance)
                   throws org.rocksdb.RocksDBException,
                          IOException

Throws:

org.rocksdb.RocksDBException

IOException

Method Detail

getPartitioningSchema

public TimePartitionSchema getPartitioningSchema()

getParameterIdDb

public ParameterIdDb getParameterIdDb()

getParameterGroupIdDb

public ParameterGroupIdDb getParameterGroupIdDb()

getYamcsInstance

public String getYamcsInstance()

writeToArchive

public void writeToArchive(PGSegment pgs)
                    throws org.rocksdb.RocksDBException,
                           IOException

Throws:

org.rocksdb.RocksDBException

IOException

writeToArchive

public void writeToArchive(long segStart,
                           Collection<PGSegment> pgList)
                    throws org.rocksdb.RocksDBException,
                           IOException

Throws:

org.rocksdb.RocksDBException

IOException

createAndGetPartition

public ParameterArchiveV2.Partition createAndGetPartition(long segStart)
                                                   throws org.rocksdb.RocksDBException

get partition for segment, creating it if it doesn't exist

Parameters:

segStart -

Throws:

org.rocksdb.RocksDBException

reprocess

public Future<?> reprocess(long start,
                           long stop)

getPartitions

public List<ParameterArchiveV2.Partition> getPartitions(long start,
                                                        long stop,
                                                        boolean ascending)

a copy of the partitions from start to stop inclusive

Parameters:

start -

stop -

Returns:

a sorted list of partitions

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

printKeys

public void printKeys(PrintStream out)
               throws DecodingException,
                      org.rocksdb.RocksDBException,
                      IOException

Throws:

DecodingException

org.rocksdb.RocksDBException

IOException

deletePartitions

public List<ParameterArchiveV2.Partition> deletePartitions(long start,
                                                           long stop)
                                                    throws org.rocksdb.RocksDBException

Delete all partitions that overlap with [start, stop) segment.

Parameters:

start -

stop -

Returns:

all the partitions removed

Throws:

org.rocksdb.RocksDBException

getIterator

public org.rocksdb.RocksIterator getIterator(ParameterArchiveV2.Partition p)
                                      throws org.rocksdb.RocksDBException,
                                             IOException

Throws:

org.rocksdb.RocksDBException

IOException

getTimeSegment

public SortedTimeSegment getTimeSegment(ParameterArchiveV2.Partition p,
                                        long segmentStart,
                                        int parameterGroupId)
                                 throws org.rocksdb.RocksDBException,
                                        IOException

Throws:

org.rocksdb.RocksDBException

IOException

getTablespace

public Tablespace getTablespace()