com.espertech.esper.runtime.internal.namedwindow

Class NamedWindowDispatchServiceImpl

java.lang.Object

com.espertech.esper.runtime.internal.namedwindow.NamedWindowDispatchServiceImpl

All Implemented Interfaces:

com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService

public class NamedWindowDispatchServiceImpl
extends Object
implements com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService

This service hold for each named window a dedicated processor and a lock to the named window. This lock is shrared between the named window and on-delete statements.

Constructor Summary

Constructors

Constructor and Description

NamedWindowDispatchServiceImpl(com.espertech.esper.common.internal.schedule.SchedulingService schedulingService, com.espertech.esper.common.internal.epl.variable.core.VariableManagementService variableService, com.espertech.esper.common.internal.epl.table.core.TableManagementService tableManagementService, boolean isPrioritized, com.espertech.esper.common.internal.util.ManagedReadWriteLock eventProcessingRWLock, com.espertech.esper.common.internal.settings.ExceptionHandlingService exceptionHandlingService, com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService metricReportingService)

Method Summary

Modifier and Type	Method and Description
void	addDispatch(com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerLatchFactory latchFactory, com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDeltaData delta, Map<com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle,List<com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerView>> consumers)
void	destroy()
boolean	dispatch()
LinkedHashMap<com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerView,com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDeltaData>	getDeltaPerConsumer(Object perStmtObj, com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle)

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedWindowDispatchServiceImpl

public NamedWindowDispatchServiceImpl(com.espertech.esper.common.internal.schedule.SchedulingService schedulingService,
                                      com.espertech.esper.common.internal.epl.variable.core.VariableManagementService variableService,
                                      com.espertech.esper.common.internal.epl.table.core.TableManagementService tableManagementService,
                                      boolean isPrioritized,
                                      com.espertech.esper.common.internal.util.ManagedReadWriteLock eventProcessingRWLock,
                                      com.espertech.esper.common.internal.settings.ExceptionHandlingService exceptionHandlingService,
                                      com.espertech.esper.common.internal.metrics.stmtmetrics.MetricReportingService metricReportingService)

Method Detail

destroy

public void destroy()

Specified by:

destroy in interface com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService

addDispatch

public void addDispatch(com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerLatchFactory latchFactory,
                        com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDeltaData delta,
                        Map<com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle,List<com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerView>> consumers)

Specified by:

addDispatch in interface com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService

dispatch

public boolean dispatch()

Specified by:

dispatch in interface com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDispatchService

getDeltaPerConsumer

public LinkedHashMap<com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowConsumerView,com.espertech.esper.common.internal.epl.namedwindow.consume.NamedWindowDeltaData> getDeltaPerConsumer(Object perStmtObj,
                                                                                                                                                                                                               com.espertech.esper.common.internal.context.util.EPStatementAgentInstanceHandle handle)