Package | Description |
---|---|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.core |
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.epl.expression.dot |
Chained expression functionality.
|
com.espertech.esper.epl.variable |
Variable service and variable collections
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
Constructor and Description |
---|
AggSvcGroupByReclaimAgedEvalFuncVariable(VariableReader variableReader) |
Modifier and Type | Field and Description |
---|---|
protected VariableReader |
MethodPollingExecStrategyBase.variableReader |
Modifier and Type | Method and Description |
---|---|
VariableReader |
MethodPollingViewableMeta.getVariableReader() |
Constructor and Description |
---|
MethodPollingExecStrategyBase(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyBaseArray(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyBaseCollection(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyBaseIterator(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyEventBeans(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyMapArray(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyMapCollection(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyMapIterator(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyMapPlain(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyOAArray(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyOACollection(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyOAIterator(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyOAPlain(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyPOJOArray(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyPOJOCollection(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyPOJOIterator(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingExecStrategyPOJOPlain(EventAdapterService eventAdapterService,
net.sf.cglib.reflect.FastMethod method,
EventType eventType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
VariableReader variableReader,
String variableName,
VariableService variableService) |
MethodPollingViewableMeta(Class methodProviderClass,
boolean isStaticMethod,
Map<String,Object> optionalMapType,
LinkedHashMap<String,Object> optionalOaType,
Object invocationTarget,
MethodPollingExecStrategyEnum strategy,
boolean isCollection,
boolean isIterator,
VariableReader variableReader,
String variableName,
EventType eventTypeEventBeanArray,
ExprNodeScript scriptExpression) |
RowLimitProcessor(VariableReader numRowsVariableReader,
VariableReader offsetVariableReader,
int currentRowLimit,
int currentOffset) |
Modifier and Type | Method and Description |
---|---|
VariableReader |
ExprDotNodeForgeVariable.getVariableReader() |
Constructor and Description |
---|
ExprDotNodeForgeVariable(ExprDotNodeImpl parent,
VariableReader variableReader,
ExprDotStaticMethodWrap resultWrapLambda,
ExprDotForge[] chainForge) |
Modifier and Type | Method and Description |
---|---|
VariableReader |
VariableServiceImpl.getReader(String variableName,
int agentInstanceIdAccessor) |
VariableReader |
VariableService.getReader(String variableName,
int agentInstanceIdAccessor)
Returns a reader that provides access to variable values.
|
Modifier and Type | Method and Description |
---|---|
ConcurrentHashMap<Integer,VariableReader> |
VariableServiceImpl.getReadersPerCP(String variableName) |
ConcurrentHashMap<Integer,VariableReader> |
VariableService.getReadersPerCP(String variableName) |
Map<String,VariableReader> |
VariableServiceImpl.getVariableReadersNonCP() |
Map<String,VariableReader> |
VariableService.getVariableReadersNonCP()
Returns a map of variable name and reader, for thread-safe iteration.
|
Constructor and Description |
---|
OutputConditionCount(OutputCallback outputCallback,
long eventRate,
VariableReader variableReader) |
OutputConditionPolledCount(OutputConditionPolledCountFactory factory,
OutputConditionPolledCountState state,
VariableReader optionalVariableReader) |