com.espertech.esper.epl.variable
Class VariableReadWritePackage

java.lang.Object
  com.espertech.esper.epl.variable.VariableReadWritePackage

public class VariableReadWritePackage
extends java.lang.Object

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

Constructor Summary

VariableReadWritePackage(java.util.List<OnTriggerSetAssignment> assignments, VariableService variableService, EventAdapterService eventAdapterService)
Ctor.

Method Summary

java.util.Map<java.lang.String,java.lang.Object>	getVariableTypes() Returns a map of variable names and type of variable.
java.util.Map<java.lang.String,java.lang.Object>	iterate(int agentInstanceId) Iterate returning all values.
void	writeVariables(VariableService variableService, EventBean[] eventsPerStream, java.util.Map<java.lang.String,java.lang.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(java.util.List<OnTriggerSetAssignment> assignments,
                                VariableService variableService,
                                EventAdapterService eventAdapterService)
                         throws ExprValidationException

Ctor.

Parameters:

assignments - the list of variable assignments

variableService - variable service

eventAdapterService - event adapters

Throws:

ExprValidationException - when variables cannot be found

Method Detail

writeVariables

public void writeVariables(VariableService variableService,
                           EventBean[] eventsPerStream,
                           java.util.Map<java.lang.String,java.lang.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 java.util.Map<java.lang.String,java.lang.Object> getVariableTypes()

Returns a map of variable names and type of variable.

Returns:

variables

iterate

public java.util.Map<java.lang.String,java.lang.Object> iterate(int agentInstanceId)

Iterate returning all values.

Returns:

map of values