org.yamcs.parameterarchive

Class ParameterArchive

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.parameterarchive.ParameterArchive

All Implemented Interfaces:

com.google.common.util.concurrent.Service

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

Nested Class Summary

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
ParameterArchive(String instance)
ParameterArchive(String instance, Map<String,Object> args)

Method Summary

Modifier and Type	Method and Description
NavigableMap<Long,org.yamcs.parameterarchive.ParameterArchive.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(org.yamcs.parameterarchive.ParameterArchive.Partition p)
ParameterGroupIdDb	getParameterGroupIdDb()
ParameterIdDb	getParameterIdDb()
NavigableMap<Long,org.yamcs.parameterarchive.ParameterArchive.Partition>	getPartitions(long startPartitionId, long stopPartitionId) a copy of the partitions from start to stop inclusive
SortedTimeSegment	getTimeSegment(org.yamcs.parameterarchive.ParameterArchive.Partition p, long segmentStart, int parameterGroupId)
String	getYamcsInstance()
void	printKeys(PrintStream out)
void	printStats(PrintStream out)
Future<?>	reprocess(long start, long stop)
void	writeToArchive(Collection<PGSegment> pgList)

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

ParameterArchive

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

Throws:

IOException

org.rocksdb.RocksDBException

ParameterArchive

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

Throws:

org.rocksdb.RocksDBException

IOException

Method Detail

getParameterIdDb

public ParameterIdDb getParameterIdDb()

getParameterGroupIdDb

public ParameterGroupIdDb getParameterGroupIdDb()

getYamcsInstance

public String getYamcsInstance()

writeToArchive

public void writeToArchive(Collection<PGSegment> pgList)
                    throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

reprocess

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

getPartitions

public NavigableMap<Long,org.yamcs.parameterarchive.ParameterArchive.Partition> getPartitions(long startPartitionId,
                                                                                              long stopPartitionId)

a copy of the partitions from start to stop inclusive

Parameters:

startPartitionId -

stopPartitionId -

Returns:

a navigable map of partitions sorted by their id

getIterator

public org.rocksdb.RocksIterator getIterator(org.yamcs.parameterarchive.ParameterArchive.Partition p)

getTimeSegment

public SortedTimeSegment getTimeSegment(org.yamcs.parameterarchive.ParameterArchive.Partition p,
                                        long segmentStart,
                                        int parameterGroupId)
                                 throws org.rocksdb.RocksDBException,
                                        DecodingException

Throws:

org.rocksdb.RocksDBException

DecodingException

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

printStats

public void printStats(PrintStream out)

printKeys

public void printKeys(PrintStream out)

deletePartitions

public NavigableMap<Long,org.yamcs.parameterarchive.ParameterArchive.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