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