Module org.yamcs.core

Package org.yamcs.parameterarchive

Class BackFiller

java.lang.Object

org.yamcs.parameterarchive.BackFiller

All Implemented Interfaces:

StreamSubscriber

public class BackFiller
extends Object
implements StreamSubscriber

Back-fills the parameter archive by triggering replays: - either regularly scheduled replays - or monitor data streams (tm, param) and keep track of which segments have to be rebuild

Method Summary

Modifier and Type	Method	Description
static Spec	getSpec()
void	onTuple(Stream stream, Tuple tuple)
Future<?>	scheduleFillingTask(long start, long stop)
void	shutDown()
void	streamClosed(Stream stream)

Methods inherited from class java.lang.Object

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

Method Details

getSpec

public static Spec getSpec()

scheduleFillingTask

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

shutDown

public void shutDown()
              throws InterruptedException

Throws:

InterruptedException

onTuple

public void onTuple(Stream stream,
 Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream stream)

Specified by:

streamClosed in interface StreamSubscriber