Class VariableReadWritePackage
java.lang.Object
com.espertech.esper.common.internal.epl.variable.core.VariableReadWritePackage
A convenience class for dealing with reading and updating multiple variable values.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptioniterate
(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
(VariableTriggerWrite[] writers) void
writeVariables
(EventBean[] eventsPerStream, Map<String, Object> valuesWritten, ExprEvaluatorContext exprEvaluatorContext) Write new variable values and commit, evaluating assignment expressions using the given events per stream.
-
Field Details
-
EPTYPE
-
-
Constructor Details
-
VariableReadWritePackage
public VariableReadWritePackage()
-
-
Method Details
-
setCopyMethods
-
setAssignments
-
setWriters
-
setVariables
-
setMustCoerce
public void setMustCoerce(boolean[] mustCoerce) -
setReadersForGlobalVars
-
writeVariables
public void writeVariables(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:
eventsPerStream
- events per streamvaluesWritten
- null or an empty map to populate with written valuesexprEvaluatorContext
- expression evaluation context
-
iterate
public Map<String,Object> iterate(VariableManagementService variableManagementService, int agentInstanceId) Iterate returning all values.- Parameters:
variableManagementService
- variable managementagentInstanceId
- context partition id- Returns:
- map of values
-