org.wso2.siddhi.core.stream.handler.window

Class WindowHandler

java.lang.Object

org.wso2.siddhi.core.stream.handler.window.WindowHandler

All Implemented Interfaces:

StreamHandler, StreamElement, StreamProcessor

Direct Known Subclasses:

LengthWindowHandler, TimeBatchWindowHandler, TimeWindowHandler

public abstract class WindowHandler
extends Object
implements StreamHandler

Constructor Summary

Constructors

Constructor and Description
WindowHandler()

Method Summary

Methods

Modifier and Type	Method and Description
protected ScheduledExecutorService	getEventRemoverScheduler()
protected StreamProcessor	getNextPreStreamFlowProcessor()
protected List<QueryEventStream>	getQueryEventStreamList()
String	getStreamId()
SchedulerQueue<StreamEvent>	getWindow()
void	setNext(StreamProcessor nextPreStreamFlowProcessor)
abstract void	setParameters(Object[] parameters)
void	setPrevious(StreamElement streamElement)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.wso2.siddhi.core.stream.StreamProcessor

process

Constructor Detail

WindowHandler

public WindowHandler()

Method Detail

setNext

public void setNext(StreamProcessor nextPreStreamFlowProcessor)

Specified by:

setNext in interface StreamHandler

getQueryEventStreamList

protected List<QueryEventStream> getQueryEventStreamList()

getNextPreStreamFlowProcessor

protected StreamProcessor getNextPreStreamFlowProcessor()

getEventRemoverScheduler

protected ScheduledExecutorService getEventRemoverScheduler()

getWindow

public SchedulerQueue<StreamEvent> getWindow()

Specified by:

getWindow in interface StreamElement

setPrevious

public void setPrevious(StreamElement streamElement)

Specified by:

setPrevious in interface StreamProcessor

getStreamId

public String getStreamId()

Specified by:

getStreamId in interface StreamElement

setParameters

public abstract void setParameters(Object[] parameters)