Modifier and Type | Method and Description |
---|---|
static List<StreamReceiver> |
StreamParser.parseStream(Stream queryStream,
List<QueryEventStream> queryEventStreamList,
QueryProjector queryProjector,
ThreadPoolExecutor threadPoolExecutor) |
Modifier and Type | Method and Description |
---|---|
static Stream |
QueryFactory.joinStream(SingleStream leftStream,
JoinStream.Type type,
SingleStream rightStream) |
static Stream |
QueryFactory.joinStream(SingleStream leftStream,
JoinStream.Type type,
SingleStream rightStream,
Condition onCompare) |
static Stream |
QueryFactory.joinStream(SingleStream leftStream,
JoinStream.Type type,
SingleStream rightStream,
Condition onCompare,
JoinStream.EventTrigger trigger) |
Modifier and Type | Method and Description |
---|---|
Stream |
Query.getInputStream() |
Modifier and Type | Method and Description |
---|---|
Query |
Query.from(Stream stream) |
Modifier and Type | Class and Description |
---|---|
class |
AnonymousStream |
class |
JoinStream |
class |
SingleStream |
Modifier and Type | Method and Description |
---|---|
Stream |
JoinStream.getLeftStream() |
Stream |
JoinStream.getRightStream() |
Constructor and Description |
---|
JoinStream(Stream leftStream,
JoinStream.Type type,
Stream rightStream,
Condition onCompare,
JoinStream.EventTrigger trigger) |
Modifier and Type | Class and Description |
---|---|
class |
PatternStream |
Modifier and Type | Class and Description |
---|---|
class |
SequenceStream |
Modifier and Type | Method and Description |
---|---|
Stream |
SiddhiQLGrammarWalker.inputStream() |
Stream |
SiddhiQLGrammarWalker.joinStream() |
Copyright © 2012. All Rights Reserved.