Package org.wso2.siddhi.query.api.execution.query.input.stream

Class JoinInputStream

java.lang.Object

org.wso2.siddhi.query.api.execution.query.input.stream.InputStream

org.wso2.siddhi.query.api.execution.query.input.stream.JoinInputStream

public class JoinInputStream
extends InputStream

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	JoinInputStream.EventTrigger
static enum	JoinInputStream.Type

Constructor Summary

Constructors

Constructor	Description
JoinInputStream(SingleInputStream leftInputStream, JoinInputStream.Type type, SingleInputStream rightInputStream, Expression onCompare, Constant within, JoinInputStream.EventTrigger trigger)

Method Summary

Modifier and Type	Method	Description
List<String>	getAllStreamIds()
InputStream	getLeftInputStream()
Expression	getOnCompare()
InputStream	getRightInputStream()
JoinInputStream.EventTrigger	getTrigger()
JoinInputStream.Type	getType()
List<String>	getUniqueStreamIds()
Constant	getWithin()

Methods inherited from class org.wso2.siddhi.query.api.execution.query.input.stream.InputStream

innerStream, innerStream, joinStream, joinStream, joinStream, joinStream, joinStream, joinStream, joinStream, joinStream, patternStream, sequenceStream, stream, stream, stream

Methods inherited from class java.lang.Object

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

Constructor Details

JoinInputStream

public JoinInputStream(SingleInputStream leftInputStream,
 JoinInputStream.Type type,
 SingleInputStream rightInputStream,
 Expression onCompare,
 Constant within,
 JoinInputStream.EventTrigger trigger)

Method Details

getLeftInputStream

public InputStream getLeftInputStream()

getType

public JoinInputStream.Type getType()

getRightInputStream

public InputStream getRightInputStream()

getOnCompare

public Expression getOnCompare()

getTrigger

public JoinInputStream.EventTrigger getTrigger()

getWithin

public Constant getWithin()

getAllStreamIds

public List<String> getAllStreamIds()

Specified by:

getAllStreamIds in class InputStream

getUniqueStreamIds

public List<String> getUniqueStreamIds()

Specified by:

getUniqueStreamIds in class InputStream