com.espertech.esper.epl.variable

Class VariableReadWritePackage

java.lang.Object

com.espertech.esper.epl.variable.VariableReadWritePackage

public class VariableReadWritePackage
extends Object

A convenience class for dealing with reading and updating multiple variable values.

Constructor Summary

Constructors

Constructor and Description
VariableReadWritePackage(List<OnTriggerSetAssignment> assignments, VariableService variableService, EventAdapterService eventAdapterService, String statementName) Ctor.

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	getVariableTypes() Returns a map of variable names and type of variable.
Map<String,Object>	iterate(int agentInstanceId) Iterate returning all values.
void	writeVariables(VariableService variableService, EventBean[] eventsPerStream, Map<String,Object> valuesWritten, ExprEvaluatorContext exprEvaluatorContext) Write new variable values and commit, evaluating assignment expressions using the given events per stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

VariableReadWritePackage

public VariableReadWritePackage(List<OnTriggerSetAssignment> assignments,
                                VariableService variableService,
                                EventAdapterService eventAdapterService,
                                String statementName)
                         throws ExprValidationException

Ctor.

Parameters:

assignments - the list of variable assignments

variableService - variable service

eventAdapterService - event adapters

statementName - statement name

Throws:

ExprValidationException - when variables cannot be found

Method Detail

writeVariables

public void writeVariables(VariableService variableService,
                           EventBean[] eventsPerStream,
                           Map<String,Object> valuesWritten,
                           ExprEvaluatorContext exprEvaluatorContext)

Write new variable values and commit, evaluating assignment expressions using the given events per stream.

Populates an optional map of new values if a non-null map is passed.

Parameters:

variableService - variable service

eventsPerStream - events per stream

valuesWritten - null or an empty map to populate with written values

exprEvaluatorContext - expression evaluation context

getVariableTypes

public Map<String,Object> getVariableTypes()

Returns a map of variable names and type of variable.

Returns:

variables

iterate

public Map<String,Object> iterate(int agentInstanceId)

Iterate returning all values.

Parameters:

agentInstanceId - context partition id

Returns:

map of values