Package com.espertech.esper.common.internal.context.controller.initterm

Class ContextControllerInitTermOverlap

java.lang.Object

com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTerm

com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTermBase

com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTermOverlap

All Implemented Interfaces:

ContextControllerConditionCallback, ContextControllerEndConditionMatchEventProvider, ContextController, ContextControllerInitTermWDistinct

public class ContextControllerInitTermOverlap
extends ContextControllerInitTermBase
implements ContextControllerInitTermWDistinct

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ContextControllerInitTermOverlap.DistinctFilterFaultHandler

Field Summary

Fields inherited from class com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTermBase

initTermSvc

Fields inherited from class com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTerm

factory, realization

Constructor Summary

Constructors

Constructor	Description
ContextControllerInitTermOverlap(ContextControllerInitTermFactory factory, ContextManagerRealization realization)

Method Summary

Modifier and Type	Method	Description
void	activate(IntSeqKey path, Object[] parentPartitionKeys, EventBean optionalTriggeringEvent, Map<String,Object> optionalTriggeringPattern)
void	deactivate(IntSeqKey path, boolean terminateChildContexts)
void	destroy()
Object	getDistinctKey(EventBean eventBean)
LRUCache<Object,EventBean>	getDistinctLastTriggerEvents()
ContextControllerInitTermDistinctSvc	getDistinctSvc()
void	rangeNotification(IntSeqKey conditionPath, ContextControllerConditionNonHA originCondition, EventBean optionalTriggeringEvent, Map<String,Object> optionalTriggeringPattern, EventBean optionalTriggeringEventPattern, Map<String,Object> optionalPatternForInclusiveEval, Map<String,Object> terminationProperties)

Methods inherited from class com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTermBase

transfer, visitPartitions

Methods inherited from class com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTerm

getFactory, getRealization, populateEndConditionFromTrigger, populateEndConditionFromTrigger, visitSelectedPartitions

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.context.controller.condition.ContextControllerEndConditionMatchEventProvider

populateEndConditionFromTrigger, populateEndConditionFromTrigger

Methods inherited from interface com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTermWDistinct

getRealization

Constructor Details

ContextControllerInitTermOverlap

public ContextControllerInitTermOverlap(ContextControllerInitTermFactory factory,
 ContextManagerRealization realization)

Method Details

getDistinctLastTriggerEvents

public LRUCache<Object,EventBean> getDistinctLastTriggerEvents()

Specified by:

getDistinctLastTriggerEvents in interface ContextControllerInitTermWDistinct

activate

public void activate(IntSeqKey path,
 Object[] parentPartitionKeys,
 EventBean optionalTriggeringEvent,
 Map<String,Object> optionalTriggeringPattern)

Specified by:

activate in interface ContextController

deactivate

public void deactivate(IntSeqKey path,
 boolean terminateChildContexts)

Specified by:

deactivate in interface ContextController

Overrides:

deactivate in class ContextControllerInitTermBase

destroy

public void destroy()

Specified by:

destroy in interface ContextController

Overrides:

destroy in class ContextControllerInitTermBase

rangeNotification

public void rangeNotification(IntSeqKey conditionPath,
 ContextControllerConditionNonHA originCondition,
 EventBean optionalTriggeringEvent,
 Map<String,Object> optionalTriggeringPattern,
 EventBean optionalTriggeringEventPattern,
 Map<String,Object> optionalPatternForInclusiveEval,
 Map<String,Object> terminationProperties)

Specified by:

rangeNotification in interface ContextControllerConditionCallback

getDistinctSvc

public ContextControllerInitTermDistinctSvc getDistinctSvc()

getDistinctKey

public Object getDistinctKey(EventBean eventBean)

Specified by:

getDistinctKey in interface ContextControllerInitTermWDistinct