com.espertech.esper.epl.core

Interface EngineImportService

All Superinterfaces:

ClassLoaderProvider

All Known Implementing Classes:

EngineImportServiceImpl

public interface EngineImportService
extends ClassLoaderProvider

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

Fields inherited from interface com.espertech.esper.client.util.ClassLoaderProvider

NAME

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.
EventPropertyGetterIndexed	codegenGetter(EventPropertyGetterIndexedSPI getterSPI, String eventTypeName, String propertyExpression)
EventPropertyGetterMapped	codegenGetter(EventPropertyGetterMappedSPI getterSPI, String eventTypeName, String propertyExpression)
EventPropertyGetter	codegenGetter(EventPropertyGetterSPI getterSPI, String eventTypeName, String propertyExpression)
AggregationFactoryFactory	getAggregationFactoryFactory()
ClassForNameProvider	getClassForNameProvider()
ClassLoader	getClassLoader()
CodegenCompiler	getCodegenCompiler()
ConfigurationEngineDefaults.CodeGeneration	getCodeGeneration()
ConfigurationMethodRef	getConfigurationMethodRef(String className) Returns the method invocation caches for the from-clause for a class.
MathContext	getDefaultMathContext()
String	getEngineURI()
ClassLoader	getFastClassClassLoader(Class clazz)
ConfigurationEngineDefaults.ThreadingProfile	getThreadingProfile()
TimeAbacus	getTimeAbacus()
TimeZone	getTimeZone()
boolean	isCodegenEventPropertyGetters()
boolean	isDuckType()
boolean	isSortUsingCollator()
boolean	isUdfCache()
AdvancedIndexFactoryProvider	resolveAdvancedIndexProvider(String indexTypeName)
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.

Methods inherited from interface com.espertech.esper.client.util.ClassLoaderProvider

classloader

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()

resolveAdvancedIndexProvider

AdvancedIndexFactoryProvider resolveAdvancedIndexProvider(String indexTypeName)
                                                   throws EngineImportException

Throws:

EngineImportException

isCodegenEventPropertyGetters

boolean isCodegenEventPropertyGetters()

getCodeGeneration

ConfigurationEngineDefaults.CodeGeneration getCodeGeneration()

getCodegenCompiler

CodegenCompiler getCodegenCompiler()

codegenGetter

EventPropertyGetter codegenGetter(EventPropertyGetterSPI getterSPI,
                                  String eventTypeName,
                                  String propertyExpression)

codegenGetter

EventPropertyGetterIndexed codegenGetter(EventPropertyGetterIndexedSPI getterSPI,
                                         String eventTypeName,
                                         String propertyExpression)

codegenGetter

EventPropertyGetterMapped codegenGetter(EventPropertyGetterMappedSPI getterSPI,
                                        String eventTypeName,
                                        String propertyExpression)

getEngineURI

String getEngineURI()