org.wso2.siddhi.query.api.stream

Class JoinStream

java.lang.Object

org.wso2.siddhi.query.api.stream.JoinStream

All Implemented Interfaces:

Stream

public class JoinStream
extends Object
implements Stream

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JoinStream.EventTrigger
static class	JoinStream.Type

Constructor Summary

Constructors

Constructor and Description
JoinStream(Stream leftStream, JoinStream.Type type, Stream rightStream, Condition onCompare, JoinStream.EventTrigger trigger)

Method Summary

Methods

Modifier and Type	Method and Description
List<QueryEventStream>	constructQueryEventStreamList(Map<String,StreamDefinition> streamDefinitionMap, List<QueryEventStream> queryEventStreams)
Stream	getLeftStream()
Condition	getOnCompare()
Stream	getRightStream()
List<String>	getStreamIds()
JoinStream.EventTrigger	getTrigger()
JoinStream.Type	getType()

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinStream

public JoinStream(Stream leftStream,
          JoinStream.Type type,
          Stream rightStream,
          Condition onCompare,
          JoinStream.EventTrigger trigger)

Method Detail

getLeftStream

public Stream getLeftStream()

getType

public JoinStream.Type getType()

getRightStream

public Stream getRightStream()

getOnCompare

public Condition getOnCompare()

getTrigger

public JoinStream.EventTrigger getTrigger()

getStreamIds

public List<String> getStreamIds()

Specified by:

getStreamIds in interface Stream

constructQueryEventStreamList

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

Specified by:

constructQueryEventStreamList in interface Stream