com.espertech.esper.common.internal.epl.variable.core

Class VariableReadWritePackage

java.lang.Object

com.espertech.esper.common.internal.epl.variable.core.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()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	iterate(VariableManagementService variableManagementService, int agentInstanceId) Iterate returning all values.
void	setAssignments(VariableTriggerSetDesc[] assignments)
void	setCopyMethods(Map<EventTypeSPI,EventBeanCopyMethod> copyMethods)
void	setMustCoerce(boolean[] mustCoerce)
void	setReadersForGlobalVars(VariableReader[] readersForGlobalVars)
void	setVariables(Variable[] variables)
void	setWriters(VariableTriggerWriteDesc[] writers)
void	writeVariables(EventBean[] eventsPerStream, Map<String,Object> valuesWritten, AgentInstanceContext agentInstanceContext) 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()

Method Detail

setCopyMethods

public void setCopyMethods(Map<EventTypeSPI,EventBeanCopyMethod> copyMethods)

setAssignments

public void setAssignments(VariableTriggerSetDesc[] assignments)

setWriters

public void setWriters(VariableTriggerWriteDesc[] writers)

setVariables

public void setVariables(Variable[] variables)

setMustCoerce

public void setMustCoerce(boolean[] mustCoerce)

setReadersForGlobalVars

public void setReadersForGlobalVars(VariableReader[] readersForGlobalVars)

writeVariables

public void writeVariables(EventBean[] eventsPerStream,
                           Map<String,Object> valuesWritten,
                           AgentInstanceContext agentInstanceContext)

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:

eventsPerStream - events per stream

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

agentInstanceContext - expression evaluation context

iterate

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

Iterate returning all values.

Parameters:

variableManagementService - variable management

agentInstanceId - context partition id

Returns:

map of values