Package org.yamcs.yarch
Class WindowProcessor
java.lang.Object
org.yamcs.yarch.WindowProcessor
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic WindowProcessor
getInstance
(WindowSpecification spec, TupleDefinition aggInputDef, List<CompiledAggregateExpression> aggList, TupleDefinition aggregateOutputDef) Called when the input stream closes, the window has the opportunity to emit some tuples before closure
-
Field Details
-
aggList
-
EMPTY_RETURN
-
aggInputDef
-
-
Constructor Details
-
WindowProcessor
public WindowProcessor()
-
-
Method Details
-
getInstance
public static WindowProcessor getInstance(WindowSpecification spec, TupleDefinition aggInputDef, List<CompiledAggregateExpression> aggList, TupleDefinition aggregateOutputDef) -
newData
-
streamClosed
Called when the input stream closes, the window has the opportunity to emit some tuples before closure
-