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, getEventBean, getGroupKey, getGroupKeys, getValue
void applyEnter(EventBean[] eventsPerStream, int streamId, ExprEvaluatorContext exprEvaluatorContext)
eventsPerStream
- events per streamstreamId
- variable number that is the baseexprEvaluatorContext
- context for expression evaluatiomvoid clearResults()