com.espertech.esper.common.internal.context.controller.keyed

Class ContextControllerKeyedSvcLevelOne

java.lang.Object

com.espertech.esper.common.internal.context.controller.keyed.ContextControllerKeyedSvcLevelOne

All Implemented Interfaces:

ContextControllerKeyedSvc

public class ContextControllerKeyedSvcLevelOne
extends Object
implements ContextControllerKeyedSvc

Constructor Summary

Constructors

Constructor and Description
ContextControllerKeyedSvcLevelOne()

Method Summary

Modifier and Type	Method and Description
Collection<Integer>	deactivate(IntSeqKey controllerPath)
void	destroy()
void	keyAdd(IntSeqKey controllerPath, Object key, int subpathIdOrCPId, ContextControllerConditionNonHA terminationCondition)
int	keyGetSubpathOrCPId(IntSeqKey controllerPath, Object key)
List<ContextControllerConditionNonHA>	keyGetTermConditions(IntSeqKey controllerPath)
boolean	keyHasSeen(IntSeqKey controllerPath, Object key)
ContextControllerKeyedSvcEntry	keyRemove(IntSeqKey controllerPath, Object key)
void	keyVisit(IntSeqKey controllerPath, BiConsumer<Object,Integer> keyAndSubpathOrCPId)
void	mgmtCreate(IntSeqKey controllerPath, Object[] parentPartitionKeys)
ContextControllerFilterEntry[]	mgmtGetFilters(IntSeqKey controllerPath)
int	mgmtGetIncSubpath(IntSeqKey controllerPath)
Object[]	mgmtGetPartitionKeys(IntSeqKey controllerPath)
void	mgmtSetFilters(IntSeqKey controllerPath, ContextControllerFilterEntry[] filterEntries)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContextControllerKeyedSvcLevelOne

public ContextControllerKeyedSvcLevelOne()

Method Detail

mgmtGetPartitionKeys

public Object[] mgmtGetPartitionKeys(IntSeqKey controllerPath)

Specified by:

mgmtGetPartitionKeys in interface ContextControllerKeyedSvc

mgmtGetIncSubpath

public int mgmtGetIncSubpath(IntSeqKey controllerPath)

Specified by:

mgmtGetIncSubpath in interface ContextControllerKeyedSvc

mgmtCreate

public void mgmtCreate(IntSeqKey controllerPath,
                       Object[] parentPartitionKeys)

Specified by:

mgmtCreate in interface ContextControllerKeyedSvc

mgmtSetFilters

public void mgmtSetFilters(IntSeqKey controllerPath,
                           ContextControllerFilterEntry[] filterEntries)

Specified by:

mgmtSetFilters in interface ContextControllerKeyedSvc

mgmtGetFilters

public ContextControllerFilterEntry[] mgmtGetFilters(IntSeqKey controllerPath)

Specified by:

mgmtGetFilters in interface ContextControllerKeyedSvc

keyHasSeen

public boolean keyHasSeen(IntSeqKey controllerPath,
                          Object key)

Specified by:

keyHasSeen in interface ContextControllerKeyedSvc

keyAdd

public void keyAdd(IntSeqKey controllerPath,
                   Object key,
                   int subpathIdOrCPId,
                   ContextControllerConditionNonHA terminationCondition)

Specified by:

keyAdd in interface ContextControllerKeyedSvc

keyRemove

public ContextControllerKeyedSvcEntry keyRemove(IntSeqKey controllerPath,
                                                Object key)

Specified by:

keyRemove in interface ContextControllerKeyedSvc

keyGetTermConditions

public List<ContextControllerConditionNonHA> keyGetTermConditions(IntSeqKey controllerPath)

Specified by:

keyGetTermConditions in interface ContextControllerKeyedSvc

keyVisit

public void keyVisit(IntSeqKey controllerPath,
                     BiConsumer<Object,Integer> keyAndSubpathOrCPId)

Specified by:

keyVisit in interface ContextControllerKeyedSvc

keyGetSubpathOrCPId

public int keyGetSubpathOrCPId(IntSeqKey controllerPath,
                               Object key)

Specified by:

keyGetSubpathOrCPId in interface ContextControllerKeyedSvc

deactivate

public Collection<Integer> deactivate(IntSeqKey controllerPath)

Specified by:

deactivate in interface ContextControllerKeyedSvc

destroy

public void destroy()

Specified by:

destroy in interface ContextControllerKeyedSvc