com.espertech.esper.epl.core

Interface EngineImportService

All Known Implementing Classes:

EngineImportServiceImpl

public interface EngineImportService

Service for engine-level resolution of static methods and aggregation methods.

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXT_SINGLEROW_FUNCTION_TRANSPOSE

Method Summary

Modifier and Type	Method and Description
void	addAggregation(String functionName, ConfigurationPlugInAggregationFunction aggregationDesc) Add an aggregation function.
void	addAggregationMultiFunction(ConfigurationPlugInAggregationMultiFunction desc)
void	addAnnotationImport(String importName) Add an import for annotation-only use, such as "com.mypackage.*" or "com.mypackage.MyClass".
void	addImport(String importName) Add an import, such as "com.mypackage.*" or "com.mypackage.MyClass".
void	addSingleRow(String functionName, String singleRowFuncClass, String methodName, ConfigurationPlugInSingleRowFunction.ValueCache valueCache, ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable, boolean rethrowExceptions, String optionalEventTypeName) Add an single-row function.
AggregationFactoryFactory	getAggregationFactoryFactory()
ClassForNameProvider	getClassForNameProvider()
ClassLoader	getClassLoader()
ConfigurationMethodRef	getConfigurationMethodRef(String className) Returns the method invocation caches for the from-clause for a class.
MathContext	getDefaultMathContext()
ClassLoader	getFastClassClassLoader(Class clazz)
ConfigurationEngineDefaults.ThreadingProfile	getThreadingProfile()
TimeAbacus	getTimeAbacus()
TimeZone	getTimeZone()
boolean	isDuckType()
boolean	isSortUsingCollator()
boolean	isUdfCache()
ExprNode	resolveAggExtendedBuiltin(String name, boolean isDistinct) Resolve an extended (non-SQL std) builtin aggregation.
AggregationFunctionFactory	resolveAggregationFactory(String functionName) Used at statement compile-time to try and resolve a given function name into an aggregation method.
ConfigurationPlugInAggregationMultiFunction	resolveAggregationMultiFunction(String name)
Class	resolveAnnotation(String className) Resolves a given class name, either fully qualified and simple and imported to a annotation.
Class	resolveClass(String className, boolean forAnnotation) Resolves a given class name, either fully qualified and simple and imported to a class.
Constructor	resolveCtor(Class clazz, Class[] paramTypes) Resolves a constructor matching list of parameter types.
Method	resolveMethod(Class clazz, String methodName, 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.
Method	resolveMethodOverloadChecked(Class clazz, String methodName)
Method	resolveMethodOverloadChecked(String className, String methodName) Resolves a given class and method name to a static method, expecting the method to exist exactly once and not be overloaded, with any parameters.
Method	resolveMethodOverloadChecked(String className, String methodName, Class[] paramTypes, boolean[] allowEventBeanType, boolean[] allowEventBeanCollType) Resolves a given class, method and list of parameter types to a static method.
Method	resolveNonStaticMethodOverloadChecked(Class clazz, String methodName) Resolves a given class and method name to a non-static method, expecting the method to exist exactly once and not be overloaded, with any parameters.
Pair<Class,EngineImportSingleRowDesc>	resolveSingleRow(String functionName) Used at statement compile-time to try and resolve a given function name into an single-row function.
ExprNode	resolveSingleRowExtendedBuiltin(String name) Resolve an extended (non-SQL std) single-row function.

Field Detail

EXT_SINGLEROW_FUNCTION_TRANSPOSE

static final String EXT_SINGLEROW_FUNCTION_TRANSPOSE

See Also:

Constant Field Values

Method Detail

getConfigurationMethodRef

ConfigurationMethodRef getConfigurationMethodRef(String className)

Returns the method invocation caches for the from-clause for a class.

Parameters:

className - the class name providing the method

Returns:

cache configs

addImport

void addImport(String importName)
        throws EngineImportException

Add an import, such as "com.mypackage.*" or "com.mypackage.MyClass".

Parameters:

importName - is the import to add

Throws:

EngineImportException - if the information or format is invalid

addAnnotationImport

void addAnnotationImport(String importName)
                  throws EngineImportException

Add an import for annotation-only use, such as "com.mypackage.*" or "com.mypackage.MyClass".

Parameters:

importName - is the import to add

Throws:

EngineImportException - if the information or format is invalid

addAggregation

void addAggregation(String functionName,
                    ConfigurationPlugInAggregationFunction aggregationDesc)
             throws EngineImportException

Add an aggregation function.

Parameters:

functionName - is the name of the function to make known.

aggregationDesc - is the descriptor for the aggregation function

Throws:

EngineImportException - throw if format or information is invalid

addSingleRow

void addSingleRow(String functionName,
                  String singleRowFuncClass,
                  String methodName,
                  ConfigurationPlugInSingleRowFunction.ValueCache valueCache,
                  ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable,
                  boolean rethrowExceptions,
                  String optionalEventTypeName)
           throws EngineImportException

Add an single-row function.

Parameters:

functionName - is the name of the function to make known.

singleRowFuncClass - is the class that provides the single row function

methodName - is the name of the public static method provided by the class that provides the single row function

valueCache - setting to control value cache behavior which may cache a result value when constant parameters are passed

filterOptimizable - filter behavior setting

rethrowExceptions - for whether to rethrow

optionalEventTypeName - event type name when provided

Throws:

EngineImportException - throw if format or information is invalid

resolveAggregationFactory

AggregationFunctionFactory resolveAggregationFactory(String functionName)
                                              throws EngineImportUndefinedException,
                                                     EngineImportException

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

Parameters:

functionName - is the function name

Returns:

aggregation provider

Throws:

EngineImportUndefinedException - if the function is not a configured aggregation function

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

resolveAggregationMultiFunction

ConfigurationPlugInAggregationMultiFunction resolveAggregationMultiFunction(String name)

resolveSingleRow

Pair<Class,EngineImportSingleRowDesc> resolveSingleRow(String functionName)
                                                throws EngineImportUndefinedException,
                                                       EngineImportException

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

Parameters:

functionName - is the function name

Returns:

class name and method name pair

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

resolveMethodOverloadChecked

Method resolveMethodOverloadChecked(String className,
                                    String methodName,
                                    Class[] paramTypes,
                                    boolean[] allowEventBeanType,
                                    boolean[] allowEventBeanCollType)
                             throws EngineImportException

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

Parameters:

className - is the class name to use

methodName - is the method name

paramTypes - is parameter types match expression sub-nodes

allowEventBeanType - flag for whether event bean is allowed

allowEventBeanCollType - flag for whether event bean array is allowed

Returns:

method this resolves to

Throws:

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

resolveMethodOverloadChecked

Method resolveMethodOverloadChecked(Class clazz,
                                    String methodName)
                             throws EngineImportException

Throws:

EngineImportException

resolveCtor

Constructor resolveCtor(Class clazz,
                        Class[] paramTypes)
                 throws EngineImportException

Resolves a constructor matching list of parameter types.

Parameters:

clazz - is the class to use

paramTypes - is parameter types match expression sub-nodes

Returns:

method this resolves to

Throws:

EngineImportException - if the ctor cannot be resolved

resolveClass

Class resolveClass(String className,
                   boolean forAnnotation)
            throws EngineImportException

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

Parameters:

className - is the class name to use

forAnnotation - whether we are resolving an annotation

Returns:

class this resolves to

Throws:

EngineImportException - if there was an error resolving the class

resolveAnnotation

Class resolveAnnotation(String className)
                 throws EngineImportException

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

Parameters:

className - is the class name to use

Returns:

annotation class this resolves to

Throws:

EngineImportException - if there was an error resolving the class

resolveMethodOverloadChecked

Method resolveMethodOverloadChecked(String className,
                                    String methodName)
                             throws EngineImportException

Resolves a given class and method name to a static method, expecting the method to exist exactly once and not be overloaded, with any parameters.

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 is overloaded

resolveNonStaticMethodOverloadChecked

Method resolveNonStaticMethodOverloadChecked(Class clazz,
                                             String methodName)
                                      throws EngineImportException

Resolves a given class and method name to a non-static method, expecting the method to exist exactly once and not be overloaded, with any parameters.

Parameters:

clazz - is the class

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 is overloaded

resolveMethod

Method resolveMethod(Class clazz,
                     String methodName,
                     Class[] paramTypes,
                     boolean[] allowEventBeanType,
                     boolean[] allowEventBeanCollType)
              throws EngineImportException

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

Parameters:

clazz - is the class to look for a fitting method

methodName - is the method name

paramTypes - is parameter types match expression sub-nodes

allowEventBeanType - whether EventBean footprint is allowed

allowEventBeanCollType - whether EventBean array footprint is allowed

Returns:

method this resolves to

Throws:

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

resolveAggExtendedBuiltin

ExprNode resolveAggExtendedBuiltin(String name,
                                   boolean isDistinct)

Resolve an extended (non-SQL std) builtin aggregation.

Parameters:

name - of func

isDistinct - indicator

Returns:

aggregation func node

resolveSingleRowExtendedBuiltin

ExprNode resolveSingleRowExtendedBuiltin(String name)

Resolve an extended (non-SQL std) single-row function.

Parameters:

name - of func

Returns:

node or null

isDuckType

boolean isDuckType()

isUdfCache

boolean isUdfCache()

isSortUsingCollator

boolean isSortUsingCollator()

addAggregationMultiFunction

void addAggregationMultiFunction(ConfigurationPlugInAggregationMultiFunction desc)
                          throws EngineImportException

Throws:

EngineImportException

getDefaultMathContext

MathContext getDefaultMathContext()

getTimeZone

TimeZone getTimeZone()

getTimeAbacus

TimeAbacus getTimeAbacus()

getThreadingProfile

ConfigurationEngineDefaults.ThreadingProfile getThreadingProfile()

getAggregationFactoryFactory

AggregationFactoryFactory getAggregationFactoryFactory()

getClassForNameProvider

ClassForNameProvider getClassForNameProvider()

getFastClassClassLoader

ClassLoader getFastClassClassLoader(Class clazz)

getClassLoader

ClassLoader getClassLoader()