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

Interface ContextManager

All Superinterfaces:

FilterFaultHandler

All Known Implementing Classes:

ContextManagerResident

public interface ContextManager
extends FilterFaultHandler

Method Summary

Modifier and Type	Method	Description
void	addListener(ContextPartitionStateListener listener)
void	addStatement(ContextControllerStatementDesc statement, boolean recovery)
StatementAIResourceRegistry	allocateAgentInstanceResourceRegistry(AIRegistryRequirements registryRequirements)
ContextManagerRealization	allocateNewRealization(AgentInstanceContext agentInstanceContext)
void	clearCaches()
int	countStatements(Function<StatementContext,Boolean> filter)
void	destroyContext()
ContextAgentInstanceInfo	getContextAgentInstanceInfo(StatementContext statementContextOfStatement, int agentInstanceId)
ContextPartitionIdentifier	getContextIdentifier(int agentInstanceId)
long	getContextPartitionCount()
Set<Integer>	getContextPartitionIds(ContextPartitionSelector selector)
DataInputOutputSerde[]	getContextPartitionKeySerdes()
Map<String,Object>	getContextPartitions(int contextPartitionId)
ContextPartitionCollection	getContextPartitions(ContextPartitionSelector selector)
MappedEventBean	getContextPropertiesEvent(int contextPartitionId)
ContextRuntimeDescriptor	getContextRuntimeDescriptor()
Iterator<ContextPartitionStateListener>	getListeners()
int	getNumNestingLevels()
ContextManagerRealization	getRealization()
Map<Integer,ContextControllerStatementDesc>	getStatements()
void	removeListener(ContextPartitionStateListener listener)
void	removeListeners()
void	setStatementContext(StatementContext statementContext)
void	stopStatement(int statementId, String statementName, String statementDeploymentId)

Methods inherited from interface com.espertech.esper.common.internal.context.util.FilterFaultHandler

handleFilterFault

Method Details

setStatementContext

void setStatementContext(StatementContext statementContext)

addStatement

void addStatement(ContextControllerStatementDesc statement,
 boolean recovery)

stopStatement

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

countStatements

int countStatements(Function<StatementContext,Boolean> filter)

getStatements

Map<Integer,ContextControllerStatementDesc> getStatements()

getNumNestingLevels

int getNumNestingLevels()

getContextAgentInstanceInfo

ContextAgentInstanceInfo getContextAgentInstanceInfo(StatementContext statementContextOfStatement,
 int agentInstanceId)

getRealization

ContextManagerRealization getRealization()

getContextRuntimeDescriptor

ContextRuntimeDescriptor getContextRuntimeDescriptor()

allocateAgentInstanceResourceRegistry

StatementAIResourceRegistry allocateAgentInstanceResourceRegistry(AIRegistryRequirements registryRequirements)

getContextPartitionKeySerdes

DataInputOutputSerde[] getContextPartitionKeySerdes()

allocateNewRealization

ContextManagerRealization allocateNewRealization(AgentInstanceContext agentInstanceContext)

getContextPartitions

Map<String,Object> getContextPartitions(int contextPartitionId)

getContextPropertiesEvent

MappedEventBean getContextPropertiesEvent(int contextPartitionId)

getContextIdentifier

ContextPartitionIdentifier getContextIdentifier(int agentInstanceId)

getContextPartitions

ContextPartitionCollection getContextPartitions(ContextPartitionSelector selector)

getContextPartitionIds

Set<Integer> getContextPartitionIds(ContextPartitionSelector selector)

getContextPartitionCount

long getContextPartitionCount()

addListener

void addListener(ContextPartitionStateListener listener)

removeListener

void removeListener(ContextPartitionStateListener listener)

getListeners

Iterator<ContextPartitionStateListener> getListeners()

removeListeners

void removeListeners()

destroyContext

void destroyContext()

clearCaches

void clearCaches()