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

Class SingleInputStream

java.lang.Object

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

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

Direct Known Subclasses:

AnonymousInputStream, BasicSingleInputStream

public class SingleInputStream
extends InputStream

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	isInnerStream
protected List<StreamHandler>	streamHandlers
protected String	streamId
protected String	streamReferenceId
protected int	windowPosition

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SingleInputStream(String streamId)
protected	SingleInputStream(String streamId, boolean isInnerStream)
	SingleInputStream(String streamReferenceId, String streamId)
	SingleInputStream(String streamReferenceId, String streamId, boolean isInnerStream)
	SingleInputStream(BasicSingleInputStream basicSingleInputStream, Window window)

Method Summary

Modifier and Type	Method	Description
void	addStreamHandlers(List<StreamHandler> streamHandlers)
SingleInputStream	as(String streamReferenceId)
boolean	equals(Object o)
SingleInputStream	filter(Filter filter)
SingleInputStream	filter(Expression filterExpression)
SingleInputStream	function(String extensionName, String functionName, Expression... parameters)
SingleInputStream	function(String name, Expression... parameters)
SingleInputStream	function(StreamFunction streamFunction)
List<String>	getAllStreamIds()
List<StreamHandler>	getStreamHandlers()
String	getStreamId()
String	getStreamReferenceId()
List<String>	getUniqueStreamIds()
int	hashCode()
boolean	isInnerStream()
String	toString()

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, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

isInnerStream

protected boolean isInnerStream

streamId

protected String streamId

streamReferenceId

protected String streamReferenceId

streamHandlers

protected List<StreamHandler> streamHandlers

windowPosition

protected int windowPosition

Constructor Details

SingleInputStream

protected SingleInputStream(String streamId)

SingleInputStream

protected SingleInputStream(String streamId,
 boolean isInnerStream)

SingleInputStream

public SingleInputStream(String streamReferenceId,
 String streamId)

SingleInputStream

public SingleInputStream(String streamReferenceId,
 String streamId,
 boolean isInnerStream)

SingleInputStream

public SingleInputStream(BasicSingleInputStream basicSingleInputStream,
 Window window)

Method Details

getStreamId

public String getStreamId()

getStreamReferenceId

public String getStreamReferenceId()

getAllStreamIds

public List<String> getAllStreamIds()

Specified by:

getAllStreamIds in class InputStream

getUniqueStreamIds

public List<String> getUniqueStreamIds()

Specified by:

getUniqueStreamIds in class InputStream

as

public SingleInputStream as(String streamReferenceId)

getStreamHandlers

public List<StreamHandler> getStreamHandlers()

addStreamHandlers

public void addStreamHandlers(List<StreamHandler> streamHandlers)

filter

public SingleInputStream filter(Expression filterExpression)

filter

public SingleInputStream filter(Filter filter)

function

public SingleInputStream function(String name,
 Expression... parameters)

function

public SingleInputStream function(String extensionName,
 String functionName,
 Expression... parameters)

function

public SingleInputStream function(StreamFunction streamFunction)

isInnerStream

public boolean isInnerStream()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object