Package | Description |
---|---|
com.espertech.esper.client |
This package and its sub-packages defines the central Esper Client APIs.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.metric |
Services for metrics reporting, including global flag, repositories and threading.
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.event |
This package defines the internal event APIs.
|
com.espertech.esper.event.vaevent |
Value added events are revision events and variant events.
|
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationOperations.addAnnotationImport(String importName)
Adds a package or class to the list of automatically-imported classes and packages for use by annotations only.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
Class eventClass)
Add an name for an event type represented by Java-bean plain-old Java object events.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
ConfigurationEventTypeXMLDOM xmlDOMEventTypeDesc)
Add an name for an event type that represents org.w3c.dom.Node events.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
Map<String,Object> typeMap)
Add an name for an event type that represents java.util.Map events,
and for which each property may itself be a Map of further properties,
with unlimited nesting levels.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
Map<String,Object> typeMap,
ConfigurationEventTypeMap mapConfig)
Add a name for an event type that represents java.util.Map events,
and for which each property may itself be a Map of further properties,
with unlimited nesting levels.
|
void |
Configuration.addEventType(String eventTypeName,
Map<String,Object> typeMap,
ConfigurationEventTypeMap mapConfig) |
void |
ConfigurationOperations.addEventType(String eventTypeName,
Map<String,Object> typeMap,
String[] superTypes)
Add a name for an event type that represents java.util.Map events,
and for which each property may itself be a Map of further properties,
with unlimited nesting levels.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
Properties typeMap)
Add an event type that represents java.util.Map events.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
String eventClassName)
Add an name for an event type represented by JavaBean object events.
|
void |
ConfigurationOperations.addEventType(String eventTypeName,
String[] propertyNames,
Object[] propertyTypes)
Add an event type that represents Object-array (Object[]) events.
|
void |
Configuration.addEventType(String eventTypeName,
String[] propertyNames,
Object[] propertyTypes) |
void |
ConfigurationOperations.addEventType(String eventTypeName,
String[] propertyNames,
Object[] propertyTypes,
ConfigurationEventTypeObjectArray optionalConfiguration)
Add an event type that represents Object-array (Object[]) events.
|
void |
Configuration.addEventType(String eventTypeName,
String[] propertyNames,
Object[] propertyTypes,
ConfigurationEventTypeObjectArray config) |
void |
ConfigurationOperations.addImport(Class importClass)
Adds a class to the list of automatically-imported classes.
|
void |
ConfigurationOperations.addImport(String importName)
Adds a package or class to the list of automatically-imported classes and packages.
|
void |
ConfigurationOperations.addPlugInAggregationFunctionFactory(String functionName,
String aggregationFactoryClassName)
Adds a plug-in aggregation function given a EPL function name and an aggregation factory class name.
|
void |
Configuration.addPlugInAggregationFunctionFactory(String functionName,
String aggregationFactoryClassName) |
void |
ConfigurationOperations.addPlugInAggregationMultiFunction(ConfigurationPlugInAggregationMultiFunction config)
Adds a plug-in aggregation multi-function.
|
void |
Configuration.addPlugInAggregationMultiFunction(ConfigurationPlugInAggregationMultiFunction config) |
void |
ConfigurationOperations.addPlugInSingleRowFunction(String functionName,
String className,
String methodName)
Adds a plug-in single-row function given a EPL function name, a class name and a method name.
|
void |
Configuration.addPlugInSingleRowFunction(String functionName,
String className,
String methodName) |
void |
ConfigurationOperations.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable)
Adds a plug-in single-row function given a EPL function name, a class name, method name and setting for value-cache behavior.
|
void |
Configuration.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable) |
void |
ConfigurationOperations.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache)
Adds a plug-in single-row function given a EPL function name, a class name, method name and setting for value-cache behavior.
|
void |
Configuration.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache) |
void |
Configuration.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable)
Add single-row function with configurations.
|
void |
ConfigurationOperations.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable,
boolean rethrowExceptions)
Adds a plug-in single-row function given a EPL function name, a class name, method name and setting for value-cache behavior.
|
void |
Configuration.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable,
boolean rethrowExceptions)
Add single-row function with configurations.
|
void |
ConfigurationOperations.addVariable(String variableName,
Class type,
Object initializationValue)
Add a global variable.
|
void |
ConfigurationOperations.addVariable(String variableName,
String type,
Object initializationValue)
Add a global variable.
|
void |
Configuration.addVariable(String variableName,
String type,
Object initializationValue) |
void |
ConfigurationOperations.addVariable(String variableName,
String type,
Object initializationValue,
boolean constant)
Add a global variable, allowing constants.
|
void |
Configuration.addVariable(String variableName,
String type,
Object initializationValue,
boolean constant) |
static EPServiceProvider |
EPServiceProviderManager.getDefaultProvider(Configuration configuration)
Returns the default EPServiceProvider.
|
static EPServiceProvider |
EPServiceProviderManager.getProvider(String providerURI,
Configuration configuration)
Returns an EPServiceProvider for a given provider URI.
|
boolean |
ConfigurationOperations.removeEventType(String name,
boolean force)
Remove an event type by its name, returning an indicator whether the event type was found and removed.
|
boolean |
Configuration.removeEventType(String eventTypeName,
boolean force) |
boolean |
ConfigurationOperations.removeVariable(String name,
boolean force)
Remove a global non-context-partitioned variable by its name, returning an indicator whether the variable was found and removed.
|
boolean |
Configuration.removeVariable(String name,
boolean force) |
void |
ConfigurationOperations.replaceXMLEventType(String xmlEventTypeName,
ConfigurationEventTypeXMLDOM config)
Rebuild the XML event type based on changed type informaton, please read below for limitations.
|
void |
Configuration.replaceXMLEventType(String xmlEventTypeName,
ConfigurationEventTypeXMLDOM config) |
void |
ConfigurationOperations.setMetricsReportingDisabled()
Disable engine-level metrics reporting.
|
void |
ConfigurationOperations.setMetricsReportingEnabled()
Enable engine-level metrics reporting.
|
void |
ConfigurationOperations.setMetricsReportingInterval(String stmtGroupName,
long newIntervalMSec)
Sets a new interval for metrics reporting for a pre-configured statement group, or changes
the default statement reporting interval if supplying a null value for the statement group name.
|
void |
ConfigurationOperations.setMetricsReportingStmtDisabled(String statementName)
Disable metrics reporting for a given statement.
|
void |
ConfigurationOperations.setMetricsReportingStmtEnabled(String statementName)
Enable metrics reporting for the given statement.
|
void |
ConfigurationOperations.updateMapEventType(String mapeventTypeName,
Map<String,Object> typeMap)
Updates an existing Map event type with additional properties.
|
void |
Configuration.updateMapEventType(String mapeventTypeName,
Map<String,Object> typeMap) |
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationOperationsImpl.addEventType(String eventTypeName,
Map<String,Object> typeMap,
ConfigurationEventTypeMap mapConfig) |
void |
ConfigurationOperationsImpl.addEventType(String eventTypeName,
Map<String,Object> typeMap,
String[] superTypes) |
void |
ConfigurationOperationsImpl.addEventType(String eventTypeName,
String[] propertyNames,
Object[] propertyTypes) |
void |
ConfigurationOperationsImpl.addEventType(String eventTypeName,
String[] propertyNames,
Object[] propertyTypes,
ConfigurationEventTypeObjectArray optionalConfiguration) |
void |
ConfigurationOperationsImpl.addPlugInAggregationMultiFunction(ConfigurationPlugInAggregationMultiFunction config) |
void |
ConfigurationOperationsImpl.addPlugInSingleRowFunction(String functionName,
String className,
String methodName) |
void |
ConfigurationOperationsImpl.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable) |
void |
ConfigurationOperationsImpl.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache) |
void |
ConfigurationOperationsImpl.addPlugInSingleRowFunction(String functionName,
String className,
String methodName,
ConfigurationPlugInSingleRowFunction.ValueCache valueCache,
ConfigurationPlugInSingleRowFunction.FilterOptimizable filterOptimizable,
boolean rethrowExceptions) |
void |
ConfigurationOperationsImpl.addVariable(String variableName,
Class type,
Object initializationValue) |
void |
ConfigurationOperationsImpl.addVariable(String variableName,
String eventTypeName,
Object initializationValue) |
void |
ConfigurationOperationsImpl.addVariable(String variableName,
String type,
Object initializationValue,
boolean constant) |
protected static ExceptionHandlingService |
EPServicesContextFactoryDefault.initExceptionHandling(String engineURI,
ConfigurationEngineDefaults.ExceptionHandling exceptionHandling,
ConfigurationEngineDefaults.ConditionHandling conditionHandling,
EngineImportService engineImportService) |
boolean |
ConfigurationOperationsImpl.removeEventType(String name,
boolean force) |
boolean |
ConfigurationOperationsImpl.removeVariable(String name,
boolean force) |
void |
ConfigurationOperationsImpl.replaceXMLEventType(String xmlEventTypeName,
ConfigurationEventTypeXMLDOM config) |
void |
ConfigurationOperationsImpl.updateMapEventType(String mapeventTypeName,
Map<String,Object> typeMap) |
void |
ConfigurationOperationsImpl.updateObjectArrayEventType(String objectArrayEventTypeName,
String[] propertyNames,
Object[] propertyTypes) |
Constructor and Description |
---|
EPServiceProviderImpl(Configuration configuration,
String engineURI,
Map<String,EPServiceProviderSPI> runtimes)
Constructor - initializes services.
|
Modifier and Type | Method and Description |
---|---|
void |
MetricReportingServiceImpl.setMetricsReportingStmtDisabled(String statementName) |
void |
MetricReportingServiceImpl.setMetricsReportingStmtEnabled(String statementName) |
Modifier and Type | Method and Description |
---|---|
void |
PluggableObjectCollection.addPatternObjects(List<ConfigurationPlugInPatternObject> configPattern,
EngineImportService engineImportService)
Add a plug-in pattern object.
|
void |
PluggableObjectCollection.addViews(List<ConfigurationPlugInView> configurationPlugInViews,
List<ConfigurationPlugInVirtualDataWindow> configurationPlugInVirtualDW,
EngineImportService engineImportService)
Add a plug-in view.
|
Modifier and Type | Method and Description |
---|---|
static void |
EventTypeUtility.validateTimestampProperties(EventType eventType,
String startTimestampProperty,
String endTimestampProperty) |
Modifier and Type | Method and Description |
---|---|
void |
ValueAddEventServiceImpl.addRevisionEventType(String revisioneventTypeName,
ConfigurationRevisionEventType config,
EventAdapterService eventAdapterService) |
void |
ValueAddEventServiceImpl.addVariantStream(String variantStreamname,
ConfigurationVariantStream variantStreamConfig,
EventAdapterService eventAdapterService,
EventTypeIdGenerator eventTypeIdGenerator) |
void |
ValueAddEventService.addVariantStream(String variantEventTypeName,
ConfigurationVariantStream variantStreamConfig,
EventAdapterService eventAdapterService,
EventTypeIdGenerator eventTypeIdGenerator)
Adds a new variant stream.
|
void |
ValueAddEventServiceImpl.init(Map<String,ConfigurationRevisionEventType> configRevision,
Map<String,ConfigurationVariantStream> configVariant,
EventAdapterService eventAdapterService,
EventTypeIdGenerator eventTypeIdGenerator) |
protected static RevisionSpec |
ValueAddEventServiceImpl.validateRevision(String revisioneventTypeName,
ConfigurationRevisionEventType config,
EventAdapterService eventAdapterService)
Valiate the revision configuration.
|