com.espertech.esper.core.context.mgr
Class ContextControllerInitTerm

java.lang.Object
  com.espertech.esper.core.context.mgr.ContextControllerInitTerm

All Implemented Interfaces:

ContextController, ContextControllerConditionCallback

public class ContextControllerInitTerm
extends java.lang.Object
implements ContextController, ContextControllerConditionCallback

Field Summary

protected ContextControllerLifecycleCallback	activationCallback
protected int	currentSubpathId
protected java.util.Map<ContextControllerCondition,ContextControllerInitTermInstance>	endConditions
protected ContextControllerInitTermFactory	factory
protected int	pathId
protected ContextControllerCondition	startCondition

Constructor Summary

ContextControllerInitTerm(int pathId, ContextControllerLifecycleCallback lifecycleCallback, ContextControllerInitTermFactory factory)

Method Summary

void	activate(EventBean optionalTriggeringEvent, java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern, ContextControllerState controllerState, ContextInternalFilterAddendum filterAddendum, java.lang.Integer importPathId)
static boolean	compare(long savedStartTime, java.util.Map<java.lang.String,java.lang.Object> savedProperties, java.lang.Long savedEndTime, long existingStartTime, java.util.Map<java.lang.String,java.lang.Object> existingProperties, java.lang.Long existingEndTime)
void	deactivate()
void	deletePath(ContextPartitionIdentifier identifier)
protected boolean	determineCurrentlyRunning(ContextControllerCondition startCondition)
protected static java.util.Map<java.lang.String,java.lang.Object>	getBuiltinProperties(ContextControllerInitTermFactory factory, long startTime, java.lang.Long endTime, java.util.Map<java.lang.String,java.lang.Object> startEndpointData)
ContextControllerFactory	getFactory()
protected MatchedEventMap	getMatchedEventMap(java.util.Map<java.lang.String,java.lang.Object> builtinProperties)
int	getPathId()
void	importContextPartitions(ContextControllerState state, int pathIdToUse, ContextInternalFilterAddendum filterAddendum, AgentInstanceSelector agentInstanceSelector)
protected ContextControllerCondition	makeEndpoint(ContextDetailCondition endpoint, ContextInternalFilterAddendum filterAddendum, boolean isStartEndpoint, int subPathId)
void	rangeNotification(java.util.Map<java.lang.String,java.lang.Object> builtinProperties, ContextControllerCondition originCondition, EventBean optionalTriggeringEvent, java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern, ContextInternalFilterAddendum filterAddendum)
void	visitSelectedPartitions(ContextPartitionSelector contextPartitionSelector, ContextPartitionVisitor visitor)

Methods inherited from class java.lang.Object

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

Field Detail

pathId

protected final int pathId

activationCallback

protected final ContextControllerLifecycleCallback activationCallback

factory

protected final ContextControllerInitTermFactory factory

startCondition

protected ContextControllerCondition startCondition

endConditions

protected java.util.Map<ContextControllerCondition,ContextControllerInitTermInstance> endConditions

currentSubpathId

protected int currentSubpathId

Constructor Detail

ContextControllerInitTerm

public ContextControllerInitTerm(int pathId,
                                 ContextControllerLifecycleCallback lifecycleCallback,
                                 ContextControllerInitTermFactory factory)

Method Detail

importContextPartitions

public void importContextPartitions(ContextControllerState state,
                                    int pathIdToUse,
                                    ContextInternalFilterAddendum filterAddendum,
                                    AgentInstanceSelector agentInstanceSelector)

Specified by:

importContextPartitions in interface ContextController

deletePath

public void deletePath(ContextPartitionIdentifier identifier)

Specified by:

deletePath in interface ContextController

activate

public void activate(EventBean optionalTriggeringEvent,
                     java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
                     ContextControllerState controllerState,
                     ContextInternalFilterAddendum filterAddendum,
                     java.lang.Integer importPathId)

Specified by:

activate in interface ContextController

makeEndpoint

protected ContextControllerCondition makeEndpoint(ContextDetailCondition endpoint,
                                                  ContextInternalFilterAddendum filterAddendum,
                                                  boolean isStartEndpoint,
                                                  int subPathId)

visitSelectedPartitions

public void visitSelectedPartitions(ContextPartitionSelector contextPartitionSelector,
                                    ContextPartitionVisitor visitor)

Specified by:

visitSelectedPartitions in interface ContextController

rangeNotification

public void rangeNotification(java.util.Map<java.lang.String,java.lang.Object> builtinProperties,
                              ContextControllerCondition originCondition,
                              EventBean optionalTriggeringEvent,
                              java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
                              ContextInternalFilterAddendum filterAddendum)

Specified by:

rangeNotification in interface ContextControllerConditionCallback

getMatchedEventMap

protected MatchedEventMap getMatchedEventMap(java.util.Map<java.lang.String,java.lang.Object> builtinProperties)

determineCurrentlyRunning

protected boolean determineCurrentlyRunning(ContextControllerCondition startCondition)

getFactory

public ContextControllerFactory getFactory()

Specified by:

getFactory in interface ContextController

getPathId

public int getPathId()

Specified by:

getPathId in interface ContextController

deactivate

public void deactivate()

Specified by:

deactivate in interface ContextController

getBuiltinProperties

protected static java.util.Map<java.lang.String,java.lang.Object> getBuiltinProperties(ContextControllerInitTermFactory factory,
                                                                                       long startTime,
                                                                                       java.lang.Long endTime,
                                                                                       java.util.Map<java.lang.String,java.lang.Object> startEndpointData)

compare

public static boolean compare(long savedStartTime,
                              java.util.Map<java.lang.String,java.lang.Object> savedProperties,
                              java.lang.Long savedEndTime,
                              long existingStartTime,
                              java.util.Map<java.lang.String,java.lang.Object> existingProperties,
                              java.lang.Long existingEndTime)