org.wso2.siddhi.query.api.stream

Class SingleStream

java.lang.Object

org.wso2.siddhi.query.api.stream.SingleStream

All Implemented Interfaces:

PatternElement, SequenceElement, Stream

Direct Known Subclasses:

AnonymousStream

public class SingleStream
extends Object
implements Stream, SequenceElement, PatternElement

Field Summary

Fields

Modifier and Type	Field and Description
protected List<Handler>	handlerList
protected boolean	isCounterStream
protected StreamDefinition	streamDefinition
protected String	streamId
protected String	streamReferenceId

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SingleStream(String streamId)
	SingleStream(String streamReferenceId, String streamId)

Method Summary

Methods

Modifier and Type	Method and Description
SingleStream	addHandler(Handler handler)
List<QueryEventStream>	constructQueryEventStreamList(Map<String,StreamDefinition> streamDefinitionMap, List<QueryEventStream> queryEventStreams)
List<Handler>	getHandlerList()
String	getStreamId()
List<String>	getStreamIds()
String	getStreamReferenceId()
SingleStream	handler(Condition filterCondition)
SingleStream	handler(Handler.Type type, String name, Object... parameters)
void	setCounterStream(boolean counterStream)
SingleStream	setStreamReferenceId(String streamReferenceId)

Methods inherited from class java.lang.Object

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

Field Detail

streamId

protected String streamId

streamDefinition

protected StreamDefinition streamDefinition

streamReferenceId

protected String streamReferenceId

handlerList

protected List<Handler> handlerList

isCounterStream

protected boolean isCounterStream

Constructor Detail

SingleStream

protected SingleStream(String streamId)

SingleStream

public SingleStream(String streamReferenceId,
            String streamId)

Method Detail

handler

public SingleStream handler(Handler.Type type,
                   String name,
                   Object... parameters)

addHandler

public SingleStream addHandler(Handler handler)

getStreamId

public String getStreamId()

getStreamReferenceId

public String getStreamReferenceId()

setStreamReferenceId

public SingleStream setStreamReferenceId(String streamReferenceId)

getHandlerList

public List<Handler> getHandlerList()

handler

public SingleStream handler(Condition filterCondition)

getStreamIds

public List<String> getStreamIds()

Specified by:

getStreamIds in interface Stream

setCounterStream

public void setCounterStream(boolean counterStream)

constructQueryEventStreamList

public List<QueryEventStream> constructQueryEventStreamList(Map<String,StreamDefinition> streamDefinitionMap,
                                                   List<QueryEventStream> queryEventStreams)

Specified by:

constructQueryEventStreamList in interface Stream