Interface AggregationMultiFunctionAggregationMethod
- All Known Implementing Classes:
AggregationMethodCountMinSketchFreq
,AggregationMethodCountMinSketchTopK
,AggregationMethodLinearCount
,AggregationMethodLinearFirstLast
,AggregationMethodLinearFirstLastIndex
,AggregationMethodLinearListReference
,AggregationMethodLinearWindow
,AggregationMethodSortedEventsBetweenEval
,AggregationMethodSortedKeyedEval
,AggregationMethodSortedMinMaxBy
,AggregationMethodSortedNoParamEval
,AggregationMethodSortedSubmapEval
,AggregationMethodSortedWindow
public interface AggregationMultiFunctionAggregationMethod
Aggregation method that operates on aggregation multi-function state such as provided by a multi-function aggregation (standalone or table column).
-
Field Summary
-
Method Summary
Modifier and TypeMethodDescriptiongetValue
(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns the plain valuedefault Collection
getValueCollectionEvents
(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return a collection of events or null when not available.default Collection
getValueCollectionScalar
(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return a collection of values or null when not available.default EventBean
getValueEventBean
(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns a single event or null when not available.
-
Field Details
-
EPTYPE
Type information.
-
-
Method Details
-
getValue
Object getValue(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns the plain value- Parameters:
aggColNum
- column numberrow
- aggregation roweventsPerStream
- eventsisNewData
- new-data flagexprEvaluatorContext
- evaluation context- Returns:
- value
-
getValueCollectionEvents
default Collection getValueCollectionEvents(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return a collection of events or null when not available. TheEPChainableType
returned by the handler indicates whether the compiler allows operations on events.- Parameters:
aggColNum
- column numberrow
- aggregation roweventsPerStream
- eventsisNewData
- new-data flagexprEvaluatorContext
- evaluation context- Returns:
- collection of
EventBean
-
getValueCollectionScalar
default Collection getValueCollectionScalar(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return a collection of values or null when not available. TheEPChainableType
returned by the handler indicates whether the compiler allows operations on events.- Parameters:
aggColNum
- column numberrow
- aggregation roweventsPerStream
- eventsisNewData
- new-data flagexprEvaluatorContext
- evaluation context- Returns:
- collection of values
-
getValueEventBean
default EventBean getValueEventBean(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns a single event or null when not available. TheEPChainableType
returned by the handler indicates whether the compiler allows operations on events.- Parameters:
aggColNum
- column numberrow
- aggregation roweventsPerStream
- eventsisNewData
- new-data flagexprEvaluatorContext
- evaluation context- Returns:
- event
-