com.espertech.esper.core.service.resource
Class StatementResourceService

java.lang.Object
  com.espertech.esper.core.service.resource.StatementResourceService

public class StatementResourceService
extends java.lang.Object

Constructor Summary

StatementResourceService(boolean partitioned)

Method Summary

void	deallocatePartitioned(int agentInstanceId)
void	deallocateUnpartitioned()
java.util.Map<ContextStatePathKey,EvalRootState>	getContextEndEndpoints()
java.util.Map<ContextStatePathKey,EvalRootState>	getContextStartEndpoints()
StatementResourceHolder	getPartitioned(int agentInstanceId)
java.util.Map<java.lang.Integer,StatementResourceHolder>	getResourcesPartitioned()
StatementResourceHolder	getResourcesUnpartitioned()
StatementResourceHolder	getUnpartitioned()
void	setPartitioned(int agentInstanceId, StatementResourceHolder statementResourceHolder)
void	setUnpartitioned(StatementResourceHolder statementResourceHolder)
void	startContextPattern(EvalRootState patternStopCallback, boolean startEndpoint, ContextStatePathKey path)
void	stopContextPattern(boolean startEndpoint, ContextStatePathKey path)

Methods inherited from class java.lang.Object

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

Constructor Detail

StatementResourceService

public StatementResourceService(boolean partitioned)

Method Detail

getResourcesUnpartitioned

public StatementResourceHolder getResourcesUnpartitioned()

getResourcesPartitioned

public java.util.Map<java.lang.Integer,StatementResourceHolder> getResourcesPartitioned()

getContextEndEndpoints

public java.util.Map<ContextStatePathKey,EvalRootState> getContextEndEndpoints()

getContextStartEndpoints

public java.util.Map<ContextStatePathKey,EvalRootState> getContextStartEndpoints()

startContextPattern

public void startContextPattern(EvalRootState patternStopCallback,
                                boolean startEndpoint,
                                ContextStatePathKey path)

stopContextPattern

public void stopContextPattern(boolean startEndpoint,
                               ContextStatePathKey path)

getPartitioned

public StatementResourceHolder getPartitioned(int agentInstanceId)

setUnpartitioned

public void setUnpartitioned(StatementResourceHolder statementResourceHolder)

setPartitioned

public void setPartitioned(int agentInstanceId,
                           StatementResourceHolder statementResourceHolder)

getUnpartitioned

public StatementResourceHolder getUnpartitioned()

deallocatePartitioned

public void deallocatePartitioned(int agentInstanceId)

deallocateUnpartitioned

public void deallocateUnpartitioned()