com.espertech.esper.core.context.mgr

Class ContextManagerNested

java.lang.Object

com.espertech.esper.core.context.mgr.ContextManagerNested

All Implemented Interfaces:

ContextControllerLifecycleCallback, ContextManager, ContextIteratorHandler, FilterFaultHandler

public class ContextManagerNested
extends Object
implements ContextManager, ContextControllerLifecycleCallback, ContextIteratorHandler, FilterFaultHandler

Constructor Summary

Constructors

Constructor and Description
ContextManagerNested(ContextControllerFactoryServiceContext factoryServiceContext)

Method Summary

Modifier and Type	Method and Description
void	addStatement(ContextControllerStatementBase statement, boolean isRecoveringResilient)
ContextControllerInstanceHandle	contextPartitionInstantiate(Integer optionalContextPartitionId, int subPathId, Integer importSubpathId, ContextController originator, EventBean optionalTriggeringEvent, Map<String,Object> optionalTriggeringPattern, Object partitionKey, Map<String,Object> contextProperties, ContextControllerState states, ContextInternalFilterAddendum filterAddendum, boolean isRecoveringResilient, ContextPartitionState state)
void	contextPartitionNavigate(ContextControllerInstanceHandle existingHandle, ContextController originator, ContextControllerState controllerState, int exportedCPOrPathId, ContextInternalFilterAddendum filterAddendum, AgentInstanceSelector agentInstanceSelector, byte[] payload, boolean isRecoveringResilient)
void	contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle, Map<String,Object> terminationProperties, boolean leaveLocksAcquired, List<AgentInstance> agentInstances) Provides the sub-context that ends.
void	destroyStatement(String statementName, int statementId)
ContextStatePathDescriptor	extractDestroyPaths(ContextPartitionSelector selector)
ContextStatePathDescriptor	extractPaths(ContextPartitionSelector selector)
ContextStatePathDescriptor	extractStopPaths(ContextPartitionSelector selector)
Collection<Integer>	getAgentInstanceIds(ContextPartitionSelector contextPartitionSelector)
ContextDescriptor	getContextDescriptor()
ContextPartitionVisitorStateWithPath	getContextPartitionPathsInternal(ContextPartitionSelector selector)
ContextStateCache	getContextStateCache()
FilterSpecLookupable	getFilterLookupable(EventType eventType)
int	getNumNestingLevels()
Map<Integer,ContextControllerStatementDesc>	getStatements()
protected static ContextPartitionIdentifier[]	getTreeCompositeKey(ContextControllerFactory[] nestedContextFactories, Object initPartitionKey, ContextControllerTreeEntry treeEntry, Map<ContextController,ContextControllerTreeEntry> subcontexts)
boolean	handleFilterFault(EventBean theEvent, long version)
void	importStartPaths(ContextControllerState state, AgentInstanceSelector agentInstanceSelector)
Iterator<EventBean>	iterator(int statementId)
Iterator<EventBean>	iterator(int statementId, ContextPartitionSelector selector)
void	safeDestroy()
SafeIterator<EventBean>	safeIterator(int statementId)
SafeIterator<EventBean>	safeIterator(int statementId, ContextPartitionSelector selector)
Map<Integer,ContextPartitionDescriptor>	startPaths(ContextPartitionSelector selector)
void	stopStatement(String statementName, int statementId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContextManagerNested

public ContextManagerNested(ContextControllerFactoryServiceContext factoryServiceContext)
                     throws ExprValidationException

Throws:

ExprValidationException

Method Detail

getStatements

public Map<Integer,ContextControllerStatementDesc> getStatements()

Specified by:

getStatements in interface ContextManager

getContextDescriptor

public ContextDescriptor getContextDescriptor()

Specified by:

getContextDescriptor in interface ContextManager

getNumNestingLevels

public int getNumNestingLevels()

Specified by:

getNumNestingLevels in interface ContextManager

iterator

public Iterator<EventBean> iterator(int statementId,
                                    ContextPartitionSelector selector)

Specified by:

iterator in interface ContextIteratorHandler

safeIterator

public SafeIterator<EventBean> safeIterator(int statementId,
                                            ContextPartitionSelector selector)

Specified by:

safeIterator in interface ContextIteratorHandler

getAgentInstanceIds

public Collection<Integer> getAgentInstanceIds(ContextPartitionSelector contextPartitionSelector)

Specified by:

getAgentInstanceIds in interface ContextManager

importStartPaths

public void importStartPaths(ContextControllerState state,
                             AgentInstanceSelector agentInstanceSelector)

Specified by:

importStartPaths in interface ContextManager

getTreeCompositeKey

protected static ContextPartitionIdentifier[] getTreeCompositeKey(ContextControllerFactory[] nestedContextFactories,
                                                                  Object initPartitionKey,
                                                                  ContextControllerTreeEntry treeEntry,
                                                                  Map<ContextController,ContextControllerTreeEntry> subcontexts)

extractPaths

public ContextStatePathDescriptor extractPaths(ContextPartitionSelector selector)

Specified by:

extractPaths in interface ContextManager

extractStopPaths

public ContextStatePathDescriptor extractStopPaths(ContextPartitionSelector selector)

Specified by:

extractStopPaths in interface ContextManager

extractDestroyPaths

public ContextStatePathDescriptor extractDestroyPaths(ContextPartitionSelector selector)

Specified by:

extractDestroyPaths in interface ContextManager

startPaths

public Map<Integer,ContextPartitionDescriptor> startPaths(ContextPartitionSelector selector)

Specified by:

startPaths in interface ContextManager

getContextPartitionPathsInternal

public ContextPartitionVisitorStateWithPath getContextPartitionPathsInternal(ContextPartitionSelector selector)

addStatement

public void addStatement(ContextControllerStatementBase statement,
                         boolean isRecoveringResilient)
                  throws ExprValidationException

Specified by:

addStatement in interface ContextManager

Throws:

ExprValidationException

stopStatement

public void stopStatement(String statementName,
                          int statementId)

Specified by:

stopStatement in interface ContextManager

destroyStatement

public void destroyStatement(String statementName,
                             int statementId)

Specified by:

destroyStatement in interface ContextManager

safeDestroy

public void safeDestroy()

Specified by:

safeDestroy in interface ContextManager

getFilterLookupable

public FilterSpecLookupable getFilterLookupable(EventType eventType)

Specified by:

getFilterLookupable in interface ContextManager

contextPartitionNavigate

public void contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
                                     ContextController originator,
                                     ContextControllerState controllerState,
                                     int exportedCPOrPathId,
                                     ContextInternalFilterAddendum filterAddendum,
                                     AgentInstanceSelector agentInstanceSelector,
                                     byte[] payload,
                                     boolean isRecoveringResilient)

Specified by:

contextPartitionNavigate in interface ContextControllerLifecycleCallback

contextPartitionInstantiate

public ContextControllerInstanceHandle contextPartitionInstantiate(Integer optionalContextPartitionId,
                                                                   int subPathId,
                                                                   Integer importSubpathId,
                                                                   ContextController originator,
                                                                   EventBean optionalTriggeringEvent,
                                                                   Map<String,Object> optionalTriggeringPattern,
                                                                   Object partitionKey,
                                                                   Map<String,Object> contextProperties,
                                                                   ContextControllerState states,
                                                                   ContextInternalFilterAddendum filterAddendum,
                                                                   boolean isRecoveringResilient,
                                                                   ContextPartitionState state)

Specified by:

contextPartitionInstantiate in interface ContextControllerLifecycleCallback

handleFilterFault

public boolean handleFilterFault(EventBean theEvent,
                                 long version)

Specified by:

handleFilterFault in interface FilterFaultHandler

getContextStateCache

public ContextStateCache getContextStateCache()

Specified by:

getContextStateCache in interface ContextManager

contextPartitionTerminate

public void contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
                                      Map<String,Object> terminationProperties,
                                      boolean leaveLocksAcquired,
                                      List<AgentInstance> agentInstances)

Provides the sub-context that ends.

Specified by:

contextPartitionTerminate in interface ContextControllerLifecycleCallback

iterator

public Iterator<EventBean> iterator(int statementId)

Specified by:

iterator in interface ContextIteratorHandler

safeIterator

public SafeIterator<EventBean> safeIterator(int statementId)

Specified by:

safeIterator in interface ContextIteratorHandler