com.espertech.esper.common.internal.context.mgr

Class ContextManagerResident

java.lang.Object

com.espertech.esper.common.internal.context.mgr.ContextManagerResident

All Implemented Interfaces:

ContextManager, ContextIteratorHandler, FilterFaultHandler

public class ContextManagerResident
extends Object
implements ContextManager, ContextIteratorHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected CopyOnWriteArrayList<ContextPartitionStateListener>	listenersLazy

Constructor Summary

Constructors

Constructor and Description
ContextManagerResident(String deploymentId, ContextDefinition contextDefinition)

Method Summary

Modifier and Type	Method and Description
void	addListener(ContextPartitionStateListener listener)
void	addStatement(ContextControllerStatementDesc statement, boolean recovery)
StatementAIResourceRegistry	allocateAgentInstanceResourceRegistry(AIRegistryRequirements registryRequirements)
ContextManagerRealization	allocateNewRealization(AgentInstanceContext agentInstanceContext)
void	clearCaches()
AgentInstanceFilterProxy	computeFilterAddendum(ContextControllerStatementDesc statement, Object[] contextPartitionKeys)
int	countStatements(Function<StatementContext,Boolean> filter)
void	destroyContext()
Collection<Integer>	getAgentInstanceIds(ContextPartitionSelector selector)
ContextAgentInstanceInfo	getContextAgentInstanceInfo(StatementContext statementContextOfStatement, int agentInstanceId)
ContextDefinition	getContextDefinition()
ContextPartitionIdentifier	getContextIdentifier(int agentInstanceId)
long	getContextPartitionCount()
ContextPartitionIdentifier	getContextPartitionIdentifier(Object[] partitionKeys)
Set<Integer>	getContextPartitionIds(ContextPartitionSelector selector)
ContextPartitionIdService	getContextPartitionIdService()
DataInputOutputSerde[]	getContextPartitionKeySerdes()
DataInputOutputSerde[]	getContextPartitionKeySerdeSubset(int nestingLevel)
static DataInputOutputSerde[]	getContextPartitionKeySerdeSubset(int nestingLevel, DataInputOutputSerde[] allSerdes)
ContextPartitionCollection	getContextPartitions(ContextPartitionSelector selector)
Map<String,Object>	getContextPartitions(int contextPartitionId)
MappedEventBean	getContextPropertiesEvent(int contextPartitionId)
ContextRuntimeDescriptor	getContextRuntimeDescriptor()
Iterator<ContextPartitionStateListener>	getListeners()
CopyOnWriteArrayList<ContextPartitionStateListener>	getListenersMayNull()
int	getNumNestingLevels()
ContextManagerRealization	getRealization()
StatementContext	getStatementContextCreate()
Map<Integer,ContextControllerStatementDesc>	getStatements()
boolean	handleFilterFault(EventBean theEvent, long version)
Iterator<EventBean>	iterator(int statementId)
Iterator<EventBean>	iterator(int statementId, ContextPartitionSelector selector)
void	removeListener(ContextPartitionStateListener listener)
void	removeListeners()
SafeIterator<EventBean>	safeIterator(int statementId)
SafeIterator<EventBean>	safeIterator(int statementId, ContextPartitionSelector selector)
void	setStatementContext(StatementContext statementContext)
void	stopStatement(int statementId, String statementName, String statementDeploymentId)

Methods inherited from class java.lang.Object

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

Field Detail

listenersLazy

protected CopyOnWriteArrayList<ContextPartitionStateListener> listenersLazy

Constructor Detail

ContextManagerResident

public ContextManagerResident(String deploymentId,
                              ContextDefinition contextDefinition)

Method Detail

setStatementContext

public void setStatementContext(StatementContext statementContext)

Specified by:

setStatementContext in interface ContextManager

addStatement

public void addStatement(ContextControllerStatementDesc statement,
                         boolean recovery)

Specified by:

addStatement in interface ContextManager

stopStatement

public void stopStatement(int statementId,
                          String statementName,
                          String statementDeploymentId)

Specified by:

stopStatement in interface ContextManager

countStatements

public int countStatements(Function<StatementContext,Boolean> filter)

Specified by:

countStatements in interface ContextManager

getContextDefinition

public ContextDefinition getContextDefinition()

getRealization

public ContextManagerRealization getRealization()

Specified by:

getRealization in interface ContextManager

destroyContext

public void destroyContext()

Specified by:

destroyContext in interface ContextManager

allocateNewRealization

public ContextManagerRealization allocateNewRealization(AgentInstanceContext agentInstanceContext)

Specified by:

allocateNewRealization in interface ContextManager

getStatements

public Map<Integer,ContextControllerStatementDesc> getStatements()

Specified by:

getStatements in interface ContextManager

getStatementContextCreate

public StatementContext getStatementContextCreate()

getContextAgentInstanceInfo

public ContextAgentInstanceInfo getContextAgentInstanceInfo(StatementContext statementContextOfStatement,
                                                            int agentInstanceId)

Specified by:

getContextAgentInstanceInfo in interface ContextManager

computeFilterAddendum

public AgentInstanceFilterProxy computeFilterAddendum(ContextControllerStatementDesc statement,
                                                      Object[] contextPartitionKeys)

getContextRuntimeDescriptor

public ContextRuntimeDescriptor getContextRuntimeDescriptor()

Specified by:

getContextRuntimeDescriptor in interface ContextManager

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

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

getContextPartitions

public Map<String,Object> getContextPartitions(int contextPartitionId)

Specified by:

getContextPartitions in interface ContextManager

getContextPropertiesEvent

public MappedEventBean getContextPropertiesEvent(int contextPartitionId)

Specified by:

getContextPropertiesEvent in interface ContextManager

getContextPartitionIdentifier

public ContextPartitionIdentifier getContextPartitionIdentifier(Object[] partitionKeys)

getContextPartitions

public ContextPartitionCollection getContextPartitions(ContextPartitionSelector selector)

Specified by:

getContextPartitions in interface ContextManager

getContextPartitionIds

public Set<Integer> getContextPartitionIds(ContextPartitionSelector selector)

Specified by:

getContextPartitionIds in interface ContextManager

getContextPartitionCount

public long getContextPartitionCount()

Specified by:

getContextPartitionCount in interface ContextManager

getContextIdentifier

public ContextPartitionIdentifier getContextIdentifier(int agentInstanceId)

Specified by:

getContextIdentifier in interface ContextManager

getAgentInstanceIds

public Collection<Integer> getAgentInstanceIds(ContextPartitionSelector selector)

allocateAgentInstanceResourceRegistry

public StatementAIResourceRegistry allocateAgentInstanceResourceRegistry(AIRegistryRequirements registryRequirements)

Specified by:

allocateAgentInstanceResourceRegistry in interface ContextManager

getContextPartitionIdService

public ContextPartitionIdService getContextPartitionIdService()

getContextPartitionKeySerdes

public DataInputOutputSerde[] getContextPartitionKeySerdes()

Specified by:

getContextPartitionKeySerdes in interface ContextManager

getNumNestingLevels

public int getNumNestingLevels()

Specified by:

getNumNestingLevels in interface ContextManager

getContextPartitionKeySerdeSubset

public DataInputOutputSerde[] getContextPartitionKeySerdeSubset(int nestingLevel)

getContextPartitionKeySerdeSubset

public static DataInputOutputSerde[] getContextPartitionKeySerdeSubset(int nestingLevel,
                                                                       DataInputOutputSerde[] allSerdes)

addListener

public void addListener(ContextPartitionStateListener listener)

Specified by:

addListener in interface ContextManager

removeListener

public void removeListener(ContextPartitionStateListener listener)

Specified by:

removeListener in interface ContextManager

getListenersMayNull

public CopyOnWriteArrayList<ContextPartitionStateListener> getListenersMayNull()

getListeners

public Iterator<ContextPartitionStateListener> getListeners()

Specified by:

getListeners in interface ContextManager

removeListeners

public void removeListeners()

Specified by:

removeListeners in interface ContextManager

handleFilterFault

public boolean handleFilterFault(EventBean theEvent,
                                 long version)

Specified by:

handleFilterFault in interface FilterFaultHandler

clearCaches

public void clearCaches()

Specified by:

clearCaches in interface ContextManager