com.espertech.esper.epl.named

Class NamedWindowTailView

java.lang.Object

com.espertech.esper.epl.named.NamedWindowTailView

public class NamedWindowTailView
extends 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 NamedWindowMgmtService to consuming statements.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>>	consumersNonContext
protected EventType	eventType
protected boolean	isParentBatchWindow
protected boolean	isPrioritized
protected NamedWindowDispatchService	namedWindowDispatchService
protected NamedWindowMgmtService	namedWindowMgmtService
protected ValueAddEventProcessor	revisionProcessor
protected StatementResultService	statementResultService
protected ConfigurationEngineDefaults.Threading	threadingConfig
protected TimeSourceService	timeSourceService

Constructor Summary

Constructors

Constructor and Description
NamedWindowTailView(EventType eventType, NamedWindowMgmtService namedWindowMgmtService, NamedWindowDispatchService namedWindowDispatchService, StatementResultService statementResultService, ValueAddEventProcessor revisionProcessor, boolean prioritized, boolean parentBatchWindow, TimeSourceService timeSourceService, ConfigurationEngineDefaults.Threading threadingConfig)

Method Summary

Modifier and Type	Method and Description
NamedWindowConsumerView	addConsumer(NamedWindowConsumerDesc consumerDesc)
void	addDispatches(NamedWindowConsumerLatchFactory latchFactory, Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumersInContext, NamedWindowDeltaData delta, AgentInstanceContext agentInstanceContext)
Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>>	getConsumersNonContext()
EventType	getEventType()
NamedWindowDispatchService	getNamedWindowDispatchService()
NamedWindowMgmtService	getNamedWindowMgmtService()
ValueAddEventProcessor	getRevisionProcessor()
StatementResultService	getStatementResultService()
boolean	isParentBatchWindow() Returns true to indicate that the data window view is a batch view.
boolean	isPrioritized()
NamedWindowConsumerLatchFactory	makeLatchFactory()
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

Field Detail

eventType

protected final EventType eventType

namedWindowMgmtService

protected final NamedWindowMgmtService namedWindowMgmtService

namedWindowDispatchService

protected final NamedWindowDispatchService namedWindowDispatchService

statementResultService

protected final StatementResultService statementResultService

revisionProcessor

protected final ValueAddEventProcessor revisionProcessor

isPrioritized

protected final boolean isPrioritized

isParentBatchWindow

protected final boolean isParentBatchWindow

consumersNonContext

protected volatile Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumersNonContext

timeSourceService

protected final TimeSourceService timeSourceService

threadingConfig

protected final ConfigurationEngineDefaults.Threading threadingConfig

Constructor Detail

NamedWindowTailView

public NamedWindowTailView(EventType eventType,
                           NamedWindowMgmtService namedWindowMgmtService,
                           NamedWindowDispatchService namedWindowDispatchService,
                           StatementResultService statementResultService,
                           ValueAddEventProcessor revisionProcessor,
                           boolean prioritized,
                           boolean parentBatchWindow,
                           TimeSourceService timeSourceService,
                           ConfigurationEngineDefaults.Threading threadingConfig)

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

getNamedWindowMgmtService

public NamedWindowMgmtService getNamedWindowMgmtService()

getNamedWindowDispatchService

public NamedWindowDispatchService getNamedWindowDispatchService()

isPrioritized

public boolean isPrioritized()

getRevisionProcessor

public ValueAddEventProcessor getRevisionProcessor()

getConsumersNonContext

public Map<EPStatementAgentInstanceHandle,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

addDispatches

public void addDispatches(NamedWindowConsumerLatchFactory latchFactory,
                          Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumersInContext,
                          NamedWindowDeltaData delta,
                          AgentInstanceContext agentInstanceContext)

makeLatchFactory

public NamedWindowConsumerLatchFactory makeLatchFactory()