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

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

All Implemented Interfaces:

ContextController, ContextControllerHashedInstanceCallback

public class ContextControllerHash
extends java.lang.Object
implements ContextController, ContextControllerHashedInstanceCallback

Field Summary

protected ContextControllerLifecycleCallback	activationCallback
protected ContextInternalFilterAddendum	activationFilterAddendum
protected int	currentSubpathId
protected ContextControllerHashFactory	factory
protected java.util.List<ContextControllerHashedFilterCallback>	filterCallbacks
protected java.util.Map<java.lang.Integer,ContextControllerInstanceHandle>	partitionKeys
protected int	pathId

Constructor Summary

ContextControllerHash(int pathId, ContextControllerLifecycleCallback activationCallback, ContextControllerHashFactory factory)

Method Summary

void	activate(EventBean optionalTriggeringEvent, java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern, ContextControllerState controllerState, ContextInternalFilterAddendum activationFilterAddendum, java.lang.Integer importPathId)
protected void	activateFilters(EventBean optionalTriggeringEvent)
void	create(int id, EventBean theEvent)
void	deactivate()
void	deletePath(ContextPartitionIdentifier identifier)
ContextControllerFactory	getFactory()
int	getPathId()
void	importContextPartitions(ContextControllerState state, int pathIdToUse, ContextInternalFilterAddendum filterAddendum, AgentInstanceSelector agentInstanceSelector)
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 ContextControllerHashFactory factory

filterCallbacks

protected final java.util.List<ContextControllerHashedFilterCallback> filterCallbacks

partitionKeys

protected final java.util.Map<java.lang.Integer,ContextControllerInstanceHandle> partitionKeys

activationFilterAddendum

protected ContextInternalFilterAddendum activationFilterAddendum

currentSubpathId

protected int currentSubpathId

Constructor Detail

ContextControllerHash

public ContextControllerHash(int pathId,
                             ContextControllerLifecycleCallback activationCallback,
                             ContextControllerHashFactory 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

visitSelectedPartitions

public void visitSelectedPartitions(ContextPartitionSelector contextPartitionSelector,
                                    ContextPartitionVisitor visitor)

Specified by:

visitSelectedPartitions in interface ContextController

activate

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

Specified by:

activate in interface ContextController

activateFilters

protected void activateFilters(EventBean optionalTriggeringEvent)

create

public void create(int id,
                   EventBean theEvent)

Specified by:

create in interface ContextControllerHashedInstanceCallback

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