Package 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
    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
    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 Details

    • 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 Details

    • 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)