com.espertech.esper.core.context.mgr

Class ContextControllerPartitioned

java.lang.Object

com.espertech.esper.core.context.mgr.ContextControllerPartitioned

All Implemented Interfaces:

ContextController, ContextControllerPartitionedInstanceCreateCallback

public class ContextControllerPartitioned
extends Object
implements ContextController, ContextControllerPartitionedInstanceCreateCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected ContextControllerLifecycleCallback	activationCallback
protected int	currentSubpathId
protected ContextControllerPartitionedFactoryImpl	factory
protected List<ContextControllerPartitionedFilterCallback>	filterCallbacks
protected HashMap<Object,ContextControllerInstanceHandle>	partitionKeys
protected int	pathId

Constructor Summary

Constructors

Constructor and Description
ContextControllerPartitioned(int pathId, ContextControllerLifecycleCallback activationCallback, ContextControllerPartitionedFactoryImpl factory)

Method Summary

Modifier and Type	Method and Description
void	activate(EventBean optionalTriggeringEvent, Map<String,Object> optionalTriggeringPattern, ContextControllerState controllerState, ContextInternalFilterAddendum filterAddendum, Integer importPathId)
void	create(Object key, 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 ContextControllerPartitionedFactoryImpl factory

filterCallbacks

protected final List<ContextControllerPartitionedFilterCallback> filterCallbacks

partitionKeys

protected final HashMap<Object,ContextControllerInstanceHandle> partitionKeys

currentSubpathId

protected int currentSubpathId

Constructor Detail

ContextControllerPartitioned

public ContextControllerPartitioned(int pathId,
                                    ContextControllerLifecycleCallback activationCallback,
                                    ContextControllerPartitionedFactoryImpl 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,
                     Map<String,Object> optionalTriggeringPattern,
                     ContextControllerState controllerState,
                     ContextInternalFilterAddendum filterAddendum,
                     Integer importPathId)

Specified by:

activate in interface ContextController

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

create

public void create(Object key,
                   EventBean theEvent)

Specified by:

create in interface ContextControllerPartitionedInstanceCreateCallback