public interface AggregationServiceMatchRecognize extends AggregationResultFuture
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
int streamId,
ExprEvaluatorContext exprEvaluatorContext)
Enter a single event row consisting of one or more events per stream (each stream representing a variable).
|
void |
clearResults()
Clear current aggregation state.
|
getCollectionOfEvents, getCollectionScalar, getContextPartitionAggregationService, getEventBean, getGroupKey, getGroupKeys, getValue, setCurrentAccess
void applyEnter(EventBean[] eventsPerStream, int streamId, ExprEvaluatorContext exprEvaluatorContext)
eventsPerStream
- events per streamstreamId
- variable number that is the baseexprEvaluatorContext
- context for expression evaluatiomvoid clearResults()
Copyright © 2005–2018. All rights reserved.