com.espertech.esper.epl.named
Class NamedWindowTailView

java.lang.Object
  com.espertech.esper.epl.named.NamedWindowTailView

public class NamedWindowTailView
extends java.lang.Object

This view is hooked into a named window's view chain as the last view and handles dispatching of named window insert and remove stream results via NamedWindowService to consuming statements.

Constructor Summary

NamedWindowTailView(EventType eventType, NamedWindowService namedWindowService, StatementResultService statementResultService, ValueAddEventProcessor revisionProcessor, boolean prioritized, boolean parentBatchWindow)

Method Summary

NamedWindowConsumerView	addConsumer(NamedWindowConsumerDesc consumerDesc)
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>>	getConsumersNonContext()
EventType	getEventType()
NamedWindowService	getNamedWindowService()
ValueAddEventProcessor	getRevisionProcessor()
StatementResultService	getStatementResultService()
boolean	isParentBatchWindow() Returns true to indicate that the data window view is a batch view.
boolean	isPrioritized()
void	removeConsumer(NamedWindowConsumerView namedWindowConsumerView) Called by the consumer view to indicate it was stopped or destroyed, such that the consumer can be deregistered and further dispatches disregard this consumer.

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedWindowTailView

public NamedWindowTailView(EventType eventType,
                           NamedWindowService namedWindowService,
                           StatementResultService statementResultService,
                           ValueAddEventProcessor revisionProcessor,
                           boolean prioritized,
                           boolean parentBatchWindow)

Method Detail

isParentBatchWindow

public boolean isParentBatchWindow()

Returns true to indicate that the data window view is a batch view.

Returns:

true if batch view

getEventType

public EventType getEventType()

getStatementResultService

public StatementResultService getStatementResultService()

getNamedWindowService

public NamedWindowService getNamedWindowService()

isPrioritized

public boolean isPrioritized()

getRevisionProcessor

public ValueAddEventProcessor getRevisionProcessor()

getConsumersNonContext

public java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> getConsumersNonContext()

addConsumer

public NamedWindowConsumerView addConsumer(NamedWindowConsumerDesc consumerDesc)

removeConsumer

public void removeConsumer(NamedWindowConsumerView namedWindowConsumerView)

Called by the consumer view to indicate it was stopped or destroyed, such that the consumer can be deregistered and further dispatches disregard this consumer.

Parameters:

namedWindowConsumerView - is the consumer representative view