org.wso2.siddhi.query.api.query.input.sequence
Class SequenceStream

java.lang.Object
  org.wso2.siddhi.query.api.query.input.sequence.SequenceStream

All Implemented Interfaces:

Serializable, SequenceElement, Stream

public class SequenceStream
extends Object
implements Stream, SequenceElement

See Also:

Serialized Form

Constructor Summary

SequenceStream(SequenceElement sequenceElement, Constant within)

Method Summary

List<QueryEventSource>	constructEventStreamList(SequenceElement sequenceElement, ConcurrentMap<String,AbstractDefinition> streamTableDefinitionMap, List<QueryEventSource> queryEventSources)
List<QueryEventSource>	constructQueryEventSourceList(ConcurrentMap<String,AbstractDefinition> streamTableDefinitionMap, List<QueryEventSource> queryEventSources)
SequenceElement	getSequenceElement()
List<String>	getStreamIds()
Constant	getWithin()

Methods inherited from class java.lang.Object

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

Constructor Detail

SequenceStream

public SequenceStream(SequenceElement sequenceElement,
                      Constant within)

Method Detail

getSequenceElement

public SequenceElement getSequenceElement()

getStreamIds

public List<String> getStreamIds()

Specified by:

getStreamIds in interface Stream

constructQueryEventSourceList

public List<QueryEventSource> constructQueryEventSourceList(ConcurrentMap<String,AbstractDefinition> streamTableDefinitionMap,
                                                            List<QueryEventSource> queryEventSources)

Specified by:

constructQueryEventSourceList in interface Stream

constructEventStreamList

public List<QueryEventSource> constructEventStreamList(SequenceElement sequenceElement,
                                                       ConcurrentMap<String,AbstractDefinition> streamTableDefinitionMap,
                                                       List<QueryEventSource> queryEventSources)

getWithin

public Constant getWithin()