public class BasicSingleInputStream extends SingleInputStream
isInnerStream, streamHandlers, streamId, streamReferenceId, windowPosition
Modifier | Constructor and Description |
---|---|
protected |
BasicSingleInputStream(String streamId) |
protected |
BasicSingleInputStream(String streamId,
boolean isInnerStream) |
|
BasicSingleInputStream(String streamReferenceId,
String streamId) |
|
BasicSingleInputStream(String streamReferenceId,
String streamId,
boolean isInnerStream) |
Modifier and Type | Method and Description |
---|---|
void |
addStreamHandlers(List<StreamHandler> streamHandlers) |
BasicSingleInputStream |
as(String streamReferenceId) |
BasicSingleInputStream |
filter(Expression filterExpression) |
BasicSingleInputStream |
filter(Filter filter) |
BasicSingleInputStream |
function(StreamFunction streamFunction) |
BasicSingleInputStream |
function(String name,
Expression... parameters) |
BasicSingleInputStream |
function(String extensionNamespace,
String functionName,
Expression... parameters) |
List<StreamHandler> |
getStreamHandlers() |
String |
getStreamId() |
String |
getStreamReferenceId() |
SingleInputStream |
window(String name,
Expression... parameters) |
SingleInputStream |
window(String namespace,
String function,
Expression... parameters) |
SingleInputStream |
window(Window window) |
equals, getAllStreamIds, getUniqueStreamIds, hashCode, isInnerStream, toString
getQueryContextEndIndex, getQueryContextStartIndex, innerStream, innerStream, joinStream, joinStream, joinStream, joinStream, joinStream, joinStream, joinStream, joinStream, patternStream, sequenceStream, setQueryContextEndIndex, setQueryContextStartIndex, stream, stream, stream
protected BasicSingleInputStream(String streamId)
protected BasicSingleInputStream(String streamId, boolean isInnerStream)
public String getStreamId()
getStreamId
in class SingleInputStream
public String getStreamReferenceId()
getStreamReferenceId
in class SingleInputStream
public BasicSingleInputStream as(String streamReferenceId)
as
in class SingleInputStream
public List<StreamHandler> getStreamHandlers()
getStreamHandlers
in class SingleInputStream
public void addStreamHandlers(List<StreamHandler> streamHandlers)
addStreamHandlers
in class SingleInputStream
public BasicSingleInputStream filter(Expression filterExpression)
filter
in class SingleInputStream
public BasicSingleInputStream filter(Filter filter)
filter
in class SingleInputStream
public SingleInputStream window(String name, Expression... parameters)
public SingleInputStream window(String namespace, String function, Expression... parameters)
public SingleInputStream window(Window window)
public BasicSingleInputStream function(String name, Expression... parameters)
function
in class SingleInputStream
public BasicSingleInputStream function(String extensionNamespace, String functionName, Expression... parameters)
function
in class SingleInputStream
public BasicSingleInputStream function(StreamFunction streamFunction)
function
in class SingleInputStream
Copyright © 2018 WSO2. All rights reserved.