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

Class BasicSingleInputStream

java.lang.Object

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

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

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

public class BasicSingleInputStream
extends SingleInputStream

Field Summary

Fields inherited from class org.wso2.siddhi.query.api.execution.query.input.stream.SingleInputStream

isInnerStream, streamHandlers, streamId, streamReferenceId, windowPosition

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BasicSingleInputStream(String streamId)
protected	BasicSingleInputStream(String streamId, boolean isInnerStream)
	BasicSingleInputStream(String streamReferenceId, String streamId)
	BasicSingleInputStream(String streamReferenceId, String streamId, boolean isInnerStream)

Method Summary

Modifier and Type	Method	Description
void	addStreamHandlers(List<StreamHandler> streamHandlers)
SingleInputStream	as(String streamReferenceId)
BasicSingleInputStream	filter(Filter filter)
BasicSingleInputStream	filter(Expression filterExpression)
BasicSingleInputStream	function(String extensionName, String functionName, Expression... parameters)
BasicSingleInputStream	function(String name, Expression... parameters)
BasicSingleInputStream	function(StreamFunction streamFunction)
List<StreamHandler>	getStreamHandlers()
String	getStreamId()
String	getStreamReferenceId()
SingleInputStream	window(String namespace, String function, Expression... parameters)
SingleInputStream	window(String name, Expression... parameters)
SingleInputStream	window(Window window)

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

equals, getAllStreamIds, getUniqueStreamIds, hashCode, isInnerStream, 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

Constructor Details

BasicSingleInputStream

protected BasicSingleInputStream(String streamId)

BasicSingleInputStream

protected BasicSingleInputStream(String streamId,
 boolean isInnerStream)

BasicSingleInputStream

public BasicSingleInputStream(String streamReferenceId,
 String streamId)

BasicSingleInputStream

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

Method Details

getStreamId

public String getStreamId()

Overrides:

getStreamId in class SingleInputStream

getStreamReferenceId

public String getStreamReferenceId()

Overrides:

getStreamReferenceId in class SingleInputStream

as

public SingleInputStream as(String streamReferenceId)

Overrides:

as in class SingleInputStream

getStreamHandlers

public List<StreamHandler> getStreamHandlers()

Overrides:

getStreamHandlers in class SingleInputStream

addStreamHandlers

public void addStreamHandlers(List<StreamHandler> streamHandlers)

Overrides:

addStreamHandlers in class SingleInputStream

filter

public BasicSingleInputStream filter(Expression filterExpression)

Overrides:

filter in class SingleInputStream

filter

public BasicSingleInputStream filter(Filter filter)

Overrides:

filter in class SingleInputStream

window

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

window

public SingleInputStream window(String namespace,
 String function,
 Expression... parameters)

window

public SingleInputStream window(Window window)

function

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

Overrides:

function in class SingleInputStream

function

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

Overrides:

function in class SingleInputStream

function

public BasicSingleInputStream function(StreamFunction streamFunction)

Overrides:

function in class SingleInputStream