com.espertech.esper.epl.core
Class MethodResolutionServiceImpl

java.lang.Object
  com.espertech.esper.epl.core.MethodResolutionServiceImpl

All Implemented Interfaces:

MethodResolutionService

public class MethodResolutionServiceImpl
extends java.lang.Object
implements MethodResolutionService

Implements method resolution.

Constructor Summary

MethodResolutionServiceImpl(EngineImportService engineImportService, TimeProvider timeProvider)
Ctor.

Method Summary

void	destroyedAgentInstance(int agentInstanceId)
java.lang.Class	getAvgAggregatorType(java.lang.Class type)
java.lang.Object	getCriteriaKeyBinding(ExprEvaluator[] evaluators)
long	getCurrentRowCount(AggregationMethod[] aggregators, AggregationState[] groupStates) Returns the current row count of an aggregation, for use with resilience.
EngineImportService	getEngineImportService()
java.lang.Object	getGroupKeyBinding(AggregationLocalGroupByPlan localGroupByPlan)
java.lang.Object	getGroupKeyBinding(ExprNode[] groupKeyExpressions, AggregationGroupByRollupDesc groupByRollupDesc)
java.lang.Class	getSumAggregatorType(java.lang.Class type)
boolean	isDuckType()
boolean	isSortUsingCollator()
boolean	isUdfCache() Returns true to cache UDF results for constant parameter sets.
AggregationState	makeAccessAggLinearJoin(int agentInstanceId, int groupId, int aggregationId, int streamNum)
AggregationState	makeAccessAggLinearNonJoin(int agentInstanceId, int groupId, int aggregationId, int streamNum)
AggregationState	makeAccessAggMinMaxEver(int agentInstanceId, int groupId, int aggregationId, AggregationStateMinMaxByEverSpec spec)
AggregationState	makeAccessAggPlugin(int agentInstanceId, int groupId, int aggregationId, boolean join, PlugInAggregationMultiFunctionStateFactory providerFactory, java.lang.Object groupKey)
AggregationState	makeAccessAggSortedJoin(int agentInstanceId, int groupId, int aggregationId, AggregationStateSortedSpec spec)
AggregationState	makeAccessAggSortedNonJoin(int agentInstanceId, int groupId, int aggregationId, AggregationStateSortedSpec spec)
AggregationMethod	makeAvedevAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter) Makes a new avedev-aggregator.
AggregationMethod	makeAvgAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new avg-aggregator.
AggregationMethod	makeCountAggregator(int agentInstanceId, int groupId, int aggregationId, boolean isIgnoreNull, boolean hasFilter) Makes a new count-aggregator.
AggregationMethod	makeCountEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter, boolean ignoreNulls) Makes a new countever-value aggregator.
AggregationState	makeCountMinSketch(int agentInstanceId, int groupId, int aggregationId, CountMinSketchSpec specification)
AggregationMethod	makeDistinctAggregator(int agentInstanceId, int groupId, int aggregationId, AggregationMethod aggregationMethod, java.lang.Class childType, boolean hasFilter) Makes a new distinct-value-aggregator.
AggregationMethod	makeFirstEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new first-value aggregator.
AggregationMethod	makeLastEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new last-value aggregator.
AggregationMethod	makeLeavingAggregator(int agentInstanceId, int groupId, int aggregationId) Make leaving agg.
AggregationMethod	makeMedianAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter) Makes a new median-aggregator.
AggregationMethod	makeMinMaxAggregator(int agentInstanceId, int groupId, int aggregationId, MinMaxTypeEnum minMaxTypeEnum, java.lang.Class targetType, boolean isHasDataWindows, boolean hasFilter) Makes a new min-max-aggregator.
AggregationMethod	makeNthAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class returnType, int size) Makes a Nth element aggregator.
AggregationMethod	makeRateAggregator(int agentInstanceId, int groupId, int aggregationId) Makes a new rate-aggregator.
AggregationMethod	makeRateEverAggregator(int agentInstanceId, int groupId, int aggregationId, long interval) Makes a new rate-aggregator.
AggregationMethod	makeStddevAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter) Makes a new stddev-aggregator.
AggregationMethod	makeSumAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new sum-aggregator.
AggregationState[]	newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs)
AggregationState[]	newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel groupByRollupLevel)
AggregationMethod[]	newAggregators(AggregationMethodFactory[] prototypes, int agentInstanceId) Returns a new set of aggregators given an existing prototype-set of aggregators for a given context partition (no groups).
AggregationMethod[]	newAggregators(AggregationMethodFactory[] prototypes, int agentInstanceId, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel groupByRollupLevel) Returns a new set of aggregators given an existing prototype-set of aggregators for a given context partition and group key.
AggregationMethod[]	newAggregatorsInternal(AggregationMethodFactory[] prototypes, int agentInstanceId)
void	removeAggregators(int agentInstanceId, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel level) Opportunity to remove aggregations for a group.
AggregationFunctionFactory	resolveAggregationFactory(java.lang.String functionName) Returns a plug-in aggregation function factory for a given configured aggregation function name.
java.lang.Class	resolveClass(java.lang.String className) Resolves a given class name, either fully qualified and simple and imported to a class.
java.lang.reflect.Constructor	resolveCtor(java.lang.Class clazz, java.lang.Class[] paramTypes) Resolves matching available constructors to a list of parameter types to an instance or static method exposed by the given class.
java.lang.reflect.Method	resolveMethod(java.lang.Class clazz, java.lang.String methodName, java.lang.Class[] paramTypes, boolean[] allowEventBeanType, boolean[] allowEventBeanCollType) Resolves a given method name and list of parameter types to an instance or static method exposed by the given class.
java.lang.reflect.Method	resolveMethod(java.lang.String className, java.lang.String methodName) Resolves a given class and method name to a static method, not allowing overloaded methods and expecting the method to be found exactly once with zero or more parameters.
java.lang.reflect.Method	resolveMethod(java.lang.String className, java.lang.String methodName, java.lang.Class[] paramTypes, boolean[] allowEventBeanType, boolean[] allowEventBeanCollType) Resolves a given class, method and list of parameter types to a static method.
java.lang.reflect.Method	resolveNonStaticMethod(java.lang.Class clazz, java.lang.String methodName) Resolves a given class and method name to a non-static method, not allowing overloaded methods and expecting the method to be found exactly once with zero or more parameters.
Pair<java.lang.Class,EngineImportSingleRowDesc>	resolveSingleRow(java.lang.String functionName) Used at statement compile-time to try and resolve a given function name into an single-row function.

Methods inherited from class java.lang.Object

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

Constructor Detail

MethodResolutionServiceImpl

public MethodResolutionServiceImpl(EngineImportService engineImportService,
                                   TimeProvider timeProvider)

Ctor.

Parameters:

engineImportService - is the engine imports

timeProvider - returns time

Method Detail

isUdfCache

public boolean isUdfCache()

Description copied from interface: MethodResolutionService

Returns true to cache UDF results for constant parameter sets.

Specified by:

isUdfCache in interface MethodResolutionService

Returns:

cache UDF results config

isDuckType

public boolean isDuckType()

Specified by:

isDuckType in interface MethodResolutionService

isSortUsingCollator

public boolean isSortUsingCollator()

Specified by:

isSortUsingCollator in interface MethodResolutionService

resolveMethod

public java.lang.reflect.Method resolveMethod(java.lang.String className,
                                              java.lang.String methodName,
                                              java.lang.Class[] paramTypes,
                                              boolean[] allowEventBeanType,
                                              boolean[] allowEventBeanCollType)
                                       throws EngineImportException

Description copied from interface: MethodResolutionService

Resolves a given class, method and list of parameter types to a static method.

Specified by:

resolveMethod in interface MethodResolutionService

Parameters:

className - is the class name to use

methodName - is the method name

paramTypes - is parameter types match expression sub-nodes

allowEventBeanType - allow event bean type footprint

Returns:

method this resolves to

Throws:

EngineImportException - if the method cannot be resolved to a visible static method

resolveMethod

public java.lang.reflect.Method resolveMethod(java.lang.String className,
                                              java.lang.String methodName)
                                       throws EngineImportException

Description copied from interface: MethodResolutionService

Resolves a given class and method name to a static method, not allowing overloaded methods and expecting the method to be found exactly once with zero or more parameters.

Specified by:

resolveMethod in interface MethodResolutionService

Parameters:

className - is the class name to use

methodName - is the method name

Returns:

method this resolves to

Throws:

EngineImportException - if the method cannot be resolved to a visible static method, or if the method exists more then once with different parameters

resolveNonStaticMethod

public java.lang.reflect.Method resolveNonStaticMethod(java.lang.Class clazz,
                                                       java.lang.String methodName)
                                                throws EngineImportException

Description copied from interface: MethodResolutionService

Resolves a given class and method name to a non-static method, not allowing overloaded methods and expecting the method to be found exactly once with zero or more parameters.

Specified by:

resolveNonStaticMethod in interface MethodResolutionService

Parameters:

clazz - is the clazz to use

methodName - is the method name

Returns:

method this resolves to

Throws:

EngineImportException - if the method cannot be resolved to a visible static method, or if the method exists more then once with different parameters

resolveCtor

public java.lang.reflect.Constructor resolveCtor(java.lang.Class clazz,
                                                 java.lang.Class[] paramTypes)
                                          throws EngineImportException

Description copied from interface: MethodResolutionService

Resolves matching available constructors to a list of parameter types to an instance or static method exposed by the given class.

Specified by:

resolveCtor in interface MethodResolutionService

Parameters:

clazz - is the class to look for a fitting method

paramTypes - is parameter types match expression sub-nodes

Returns:

method this resolves to

Throws:

EngineImportException - if the method cannot be resolved to a visible static or instance method

resolveClass

public java.lang.Class resolveClass(java.lang.String className)
                             throws EngineImportException

Description copied from interface: MethodResolutionService

Resolves a given class name, either fully qualified and simple and imported to a class.

Specified by:

resolveClass in interface MethodResolutionService

Parameters:

className - is the class name to use

Returns:

class this resolves to

Throws:

EngineImportException - if there was an error resolving the class

resolveMethod

public java.lang.reflect.Method resolveMethod(java.lang.Class clazz,
                                              java.lang.String methodName,
                                              java.lang.Class[] paramTypes,
                                              boolean[] allowEventBeanType,
                                              boolean[] allowEventBeanCollType)
                                       throws EngineImportException

Description copied from interface: MethodResolutionService

Resolves a given method name and list of parameter types to an instance or static method exposed by the given class.

Specified by:

resolveMethod in interface MethodResolutionService

Parameters:

clazz - is the class to look for a fitting method

methodName - is the method name

paramTypes - is parameter types match expression sub-nodes

Returns:

method this resolves to

Throws:

EngineImportException - if the method cannot be resolved to a visible static or instance method

makeCountAggregator

public AggregationMethod makeCountAggregator(int agentInstanceId,
                                             int groupId,
                                             int aggregationId,
                                             boolean isIgnoreNull,
                                             boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new count-aggregator.

Specified by:

makeCountAggregator in interface MethodResolutionService

isIgnoreNull - is true to ignore nulls, or false to count nulls @return aggregator

resolveAggregationFactory

public AggregationFunctionFactory resolveAggregationFactory(java.lang.String functionName)
                                                     throws EngineImportUndefinedException,
                                                            EngineImportException

Description copied from interface: MethodResolutionService

Returns a plug-in aggregation function factory for a given configured aggregation function name.

Specified by:

resolveAggregationFactory in interface MethodResolutionService

Parameters:

functionName - is the aggregation function name

Returns:

aggregation-factory

Throws:

EngineImportUndefinedException - is the function name cannot be found

EngineImportException - if there was an error resolving class information

resolveSingleRow

public Pair<java.lang.Class,EngineImportSingleRowDesc> resolveSingleRow(java.lang.String functionName)
                                                                 throws EngineImportUndefinedException,
                                                                        EngineImportException

Description copied from interface: MethodResolutionService

Used at statement compile-time to try and resolve a given function name into an single-row function. Matches function name case-neutral.

Specified by:

resolveSingleRow in interface MethodResolutionService

Parameters:

functionName - is the function name

Throws:

EngineImportUndefinedException - if the function is not a configured single-row function

EngineImportException - if the function providing class could not be loaded or doesn't match

makeSumAggregator

public AggregationMethod makeSumAggregator(int agentInstanceId,
                                           int groupId,
                                           int aggregationId,
                                           java.lang.Class type,
                                           boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new sum-aggregator.

Specified by:

makeSumAggregator in interface MethodResolutionService

type - is the type to be summed up, i.e. float, long etc. @return aggregator

getSumAggregatorType

public java.lang.Class getSumAggregatorType(java.lang.Class type)

Specified by:

getSumAggregatorType in interface MethodResolutionService

makeDistinctAggregator

public AggregationMethod makeDistinctAggregator(int agentInstanceId,
                                                int groupId,
                                                int aggregationId,
                                                AggregationMethod aggregationMethod,
                                                java.lang.Class childType,
                                                boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new distinct-value-aggregator.

Specified by:

makeDistinctAggregator in interface MethodResolutionService

aggregationMethod - is the inner aggregation method

childType - is the return type of the inner expression to aggregate, if any @return aggregator

makeAvgAggregator

public AggregationMethod makeAvgAggregator(int agentInstanceId,
                                           int groupId,
                                           int aggregationId,
                                           java.lang.Class type,
                                           boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new avg-aggregator.

Specified by:

makeAvgAggregator in interface MethodResolutionService

type - the expression return type @return aggregator

getAvgAggregatorType

public java.lang.Class getAvgAggregatorType(java.lang.Class type)

Specified by:

getAvgAggregatorType in interface MethodResolutionService

makeAvedevAggregator

public AggregationMethod makeAvedevAggregator(int agentInstanceId,
                                              int groupId,
                                              int aggregationId,
                                              boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new avedev-aggregator.

Specified by:

makeAvedevAggregator in interface MethodResolutionService

Returns:

aggregator

makeMedianAggregator

public AggregationMethod makeMedianAggregator(int agentInstanceId,
                                              int groupId,
                                              int aggregationId,
                                              boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new median-aggregator.

Specified by:

makeMedianAggregator in interface MethodResolutionService

Returns:

aggregator

makeMinMaxAggregator

public AggregationMethod makeMinMaxAggregator(int agentInstanceId,
                                              int groupId,
                                              int aggregationId,
                                              MinMaxTypeEnum minMaxTypeEnum,
                                              java.lang.Class targetType,
                                              boolean isHasDataWindows,
                                              boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new min-max-aggregator.

Specified by:

makeMinMaxAggregator in interface MethodResolutionService

minMaxTypeEnum - dedicates whether to do min or max

targetType - is the type to max or min

isHasDataWindows - true for has data windows @return aggregator to use

makeStddevAggregator

public AggregationMethod makeStddevAggregator(int agentInstanceId,
                                              int groupId,
                                              int aggregationId,
                                              boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new stddev-aggregator.

Specified by:

makeStddevAggregator in interface MethodResolutionService

Returns:

aggregator

makeFirstEverValueAggregator

public AggregationMethod makeFirstEverValueAggregator(int agentInstanceId,
                                                      int groupId,
                                                      int aggregationId,
                                                      java.lang.Class type,
                                                      boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new first-value aggregator.

Specified by:

makeFirstEverValueAggregator in interface MethodResolutionService

type - of value @return aggregator

makeCountEverValueAggregator

public AggregationMethod makeCountEverValueAggregator(int agentInstanceId,
                                                      int groupId,
                                                      int aggregationId,
                                                      boolean hasFilter,
                                                      boolean ignoreNulls)

Description copied from interface: MethodResolutionService

Makes a new countever-value aggregator.

Specified by:

makeCountEverValueAggregator in interface MethodResolutionService

makeLastEverValueAggregator

public AggregationMethod makeLastEverValueAggregator(int agentInstanceId,
                                                     int groupId,
                                                     int aggregationId,
                                                     java.lang.Class type,
                                                     boolean hasFilter)

Description copied from interface: MethodResolutionService

Makes a new last-value aggregator.

Specified by:

makeLastEverValueAggregator in interface MethodResolutionService

type - of value @return aggregator

makeRateAggregator

public AggregationMethod makeRateAggregator(int agentInstanceId,
                                            int groupId,
                                            int aggregationId)

Description copied from interface: MethodResolutionService

Makes a new rate-aggregator.

Specified by:

makeRateAggregator in interface MethodResolutionService

Returns:

aggregator

makeRateEverAggregator

public AggregationMethod makeRateEverAggregator(int agentInstanceId,
                                                int groupId,
                                                int aggregationId,
                                                long interval)

Description copied from interface: MethodResolutionService

Makes a new rate-aggregator.

Specified by:

makeRateEverAggregator in interface MethodResolutionService

interval - seconds

Returns:

aggregator to use

makeNthAggregator

public AggregationMethod makeNthAggregator(int agentInstanceId,
                                           int groupId,
                                           int aggregationId,
                                           java.lang.Class returnType,
                                           int size)

Description copied from interface: MethodResolutionService

Makes a Nth element aggregator.

Specified by:

makeNthAggregator in interface MethodResolutionService

returnType - of aggregation

size - of elements @return aggregator

makeLeavingAggregator

public AggregationMethod makeLeavingAggregator(int agentInstanceId,
                                               int groupId,
                                               int aggregationId)

Description copied from interface: MethodResolutionService

Make leaving agg.

Specified by:

makeLeavingAggregator in interface MethodResolutionService

Returns:

agg

newAggregators

public AggregationMethod[] newAggregators(AggregationMethodFactory[] prototypes,
                                          int agentInstanceId)

Description copied from interface: MethodResolutionService

Returns a new set of aggregators given an existing prototype-set of aggregators for a given context partition (no groups).

Specified by:

newAggregators in interface MethodResolutionService

agentInstanceId - context partition

Returns:

new set of aggregators for this group

newAggregators

public AggregationMethod[] newAggregators(AggregationMethodFactory[] prototypes,
                                          int agentInstanceId,
                                          java.lang.Object groupKey,
                                          java.lang.Object groupKeyBinding,
                                          AggregationGroupByRollupLevel groupByRollupLevel)

Description copied from interface: MethodResolutionService

Returns a new set of aggregators given an existing prototype-set of aggregators for a given context partition and group key.

Specified by:

newAggregators in interface MethodResolutionService

Parameters:

prototypes - is the prototypes

agentInstanceId - context partition

groupKey - is the key to group-by for

Returns:

new set of aggregators for this group

newAggregatorsInternal

public AggregationMethod[] newAggregatorsInternal(AggregationMethodFactory[] prototypes,
                                                  int agentInstanceId)

getCurrentRowCount

public long getCurrentRowCount(AggregationMethod[] aggregators,
                               AggregationState[] groupStates)

Description copied from interface: MethodResolutionService

Returns the current row count of an aggregation, for use with resilience.

Specified by:

getCurrentRowCount in interface MethodResolutionService

Parameters:

aggregators - aggregators

Returns:

row count

removeAggregators

public void removeAggregators(int agentInstanceId,
                              java.lang.Object groupKey,
                              java.lang.Object groupKeyBinding,
                              AggregationGroupByRollupLevel level)

Description copied from interface: MethodResolutionService

Opportunity to remove aggregations for a group.

Specified by:

removeAggregators in interface MethodResolutionService

groupKey - that is no longer used

newAccesses

public AggregationState[] newAccesses(int agentInstanceId,
                                      boolean isJoin,
                                      AggregationStateFactory[] accessAggSpecs)

Specified by:

newAccesses in interface MethodResolutionService

newAccesses

public AggregationState[] newAccesses(int agentInstanceId,
                                      boolean isJoin,
                                      AggregationStateFactory[] accessAggSpecs,
                                      java.lang.Object groupKey,
                                      java.lang.Object groupKeyBinding,
                                      AggregationGroupByRollupLevel groupByRollupLevel)

Specified by:

newAccesses in interface MethodResolutionService

makeAccessAggLinearNonJoin

public AggregationState makeAccessAggLinearNonJoin(int agentInstanceId,
                                                   int groupId,
                                                   int aggregationId,
                                                   int streamNum)

Specified by:

makeAccessAggLinearNonJoin in interface MethodResolutionService

makeAccessAggLinearJoin

public AggregationState makeAccessAggLinearJoin(int agentInstanceId,
                                                int groupId,
                                                int aggregationId,
                                                int streamNum)

Specified by:

makeAccessAggLinearJoin in interface MethodResolutionService

makeAccessAggSortedNonJoin

public AggregationState makeAccessAggSortedNonJoin(int agentInstanceId,
                                                   int groupId,
                                                   int aggregationId,
                                                   AggregationStateSortedSpec spec)

Specified by:

makeAccessAggSortedNonJoin in interface MethodResolutionService

makeAccessAggSortedJoin

public AggregationState makeAccessAggSortedJoin(int agentInstanceId,
                                                int groupId,
                                                int aggregationId,
                                                AggregationStateSortedSpec spec)

Specified by:

makeAccessAggSortedJoin in interface MethodResolutionService

makeAccessAggMinMaxEver

public AggregationState makeAccessAggMinMaxEver(int agentInstanceId,
                                                int groupId,
                                                int aggregationId,
                                                AggregationStateMinMaxByEverSpec spec)

Specified by:

makeAccessAggMinMaxEver in interface MethodResolutionService

makeAccessAggPlugin

public AggregationState makeAccessAggPlugin(int agentInstanceId,
                                            int groupId,
                                            int aggregationId,
                                            boolean join,
                                            PlugInAggregationMultiFunctionStateFactory providerFactory,
                                            java.lang.Object groupKey)

Specified by:

makeAccessAggPlugin in interface MethodResolutionService

makeCountMinSketch

public AggregationState makeCountMinSketch(int agentInstanceId,
                                           int groupId,
                                           int aggregationId,
                                           CountMinSketchSpec specification)

Specified by:

makeCountMinSketch in interface MethodResolutionService

destroyedAgentInstance

public void destroyedAgentInstance(int agentInstanceId)

Specified by:

destroyedAgentInstance in interface MethodResolutionService

getEngineImportService

public EngineImportService getEngineImportService()

Specified by:

getEngineImportService in interface MethodResolutionService

getCriteriaKeyBinding

public java.lang.Object getCriteriaKeyBinding(ExprEvaluator[] evaluators)

Specified by:

getCriteriaKeyBinding in interface MethodResolutionService

getGroupKeyBinding

public java.lang.Object getGroupKeyBinding(ExprNode[] groupKeyExpressions,
                                           AggregationGroupByRollupDesc groupByRollupDesc)

Specified by:

getGroupKeyBinding in interface MethodResolutionService

getGroupKeyBinding

public java.lang.Object getGroupKeyBinding(AggregationLocalGroupByPlan localGroupByPlan)

Specified by:

getGroupKeyBinding in interface MethodResolutionService