Package org.yamcs.yarch

Class WindowProcessor

java.lang.Object

org.yamcs.yarch.WindowProcessor

public abstract class WindowProcessor
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
TupleDefinition	aggInputDef

Constructor Summary

Constructors

Constructor	Description
WindowProcessor()

Method Summary

Modifier and Type	Method	Description
static WindowProcessor	getInstance(WindowSpecification spec, TupleDefinition aggInputDef, List<CompiledAggregateExpression> aggList, TupleDefinition aggregateOutputDef)
protected abstract boolean	isOutsideWindow(Tuple tuple)
List<Tuple>	newData(Tuple tuple)	When windows closes, returns a list with the tuples to be emitted, otherwise returns null
protected abstract void	setFirstTuple(Tuple tuple)

Methods inherited from class java.lang.Object

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

Field Detail

aggInputDef

public TupleDefinition aggInputDef

Constructor Detail

WindowProcessor

public WindowProcessor()

Method Detail

getInstance

public static WindowProcessor getInstance(WindowSpecification spec,
                                          TupleDefinition aggInputDef,
                                          List<CompiledAggregateExpression> aggList,
                                          TupleDefinition aggregateOutputDef)

newData

public List<Tuple> newData(Tuple tuple)

When windows closes, returns a list with the tuples to be emitted, otherwise returns null

setFirstTuple

protected abstract void setFirstTuple(Tuple tuple)

isOutsideWindow

protected abstract boolean isOutsideWindow(Tuple tuple)