org.wso2.siddhi.query.api.query.input
Interface Stream

All Superinterfaces:

Serializable

All Known Subinterfaces:

FilteredStream, SingleStream, TransformedStream

All Known Implementing Classes:

AnonymousStream, BasicStream, JoinStream, PatternStream, SequenceStream, WindowStream

public interface Stream
extends Serializable

Method Summary

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

Method Detail

getStreamIds

List<String> getStreamIds()

constructQueryEventSourceList

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