Modifier and Type | Method and Description |
---|---|
SingleStream |
PatternState.getSingleStream() |
Modifier and Type | Method and Description |
---|---|
void |
PatternState.setSingleStream(SingleStream singleStream) |
Constructor and Description |
---|
AndPatternState(int stateNumber,
SingleStream singleStream) |
CountPatternState(int stateNumber,
SingleStream singleStream,
int minCount,
int maxCount) |
LogicPatternState(int stateNumber,
SingleStream singleStream) |
OrPatternState(int stateNumber,
SingleStream singleStream) |
PatternState(int stateNumber,
SingleStream singleStream) |
Modifier and Type | Method and Description |
---|---|
SingleStream |
SequenceState.getSingleStream() |
Modifier and Type | Method and Description |
---|---|
void |
SequenceState.setSingleStream(SingleStream singleStream) |
Constructor and Description |
---|
CountSequenceState(int stateNumber,
SingleStream singleStream,
int minCount,
int maxCount) |
OrSequenceState(int stateNumber,
SingleStream singleStream) |
SequenceState(int stateNumber,
SingleStream singleStream) |
Constructor and Description |
---|
SingleStreamReceiver(SingleStream inputStream,
StreamProcessor firstStreamProcessor,
ThreadPoolExecutor threadPoolExecutor) |
Modifier and Type | Method and Description |
---|---|
SingleStream |
State.getSingleStream() |
Modifier and Type | Method and Description |
---|---|
void |
State.setSingleStream(SingleStream singleStream) |
Constructor and Description |
---|
AndState(int stateNumber,
SingleStream singleStream,
int partnerNum) |
CountState(int stateNumber,
SingleStream singleStream,
int minCount,
int maxCount) |
OrState(int stateNumber,
SingleStream singleStream,
int partnerNum) |
State(int stateNumber,
SingleStream singleStream) |
Modifier and Type | Method and Description |
---|---|
static SingleStream |
QueryFactory.inputStream(String streamId) |
static SingleStream |
QueryFactory.inputStream(String streamReferenceId,
String streamId) |
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 |
---|---|
SingleStream |
Query.returnStream() |
Modifier and Type | Class and Description |
---|---|
class |
AnonymousStream |
Modifier and Type | Method and Description |
---|---|
SingleStream |
SingleStream.addHandler(Handler handler) |
SingleStream |
SingleStream.handler(Condition filterCondition) |
SingleStream |
SingleStream.handler(Handler.Type type,
String name,
Object... parameters) |
SingleStream |
SingleStream.setStreamReferenceId(String streamReferenceId) |
Modifier and Type | Method and Description |
---|---|
static PatternElement |
Pattern.count(SingleStream singleStream,
int min,
int max) |
static PatternElement |
Pattern.logical(SingleStream singleStream1,
LogicalElement.Type type,
SingleStream singleStream2) |
Modifier and Type | Method and Description |
---|---|
SingleStream |
CountElement.getSingleStream() |
SingleStream |
LogicalElement.getSingleStream1() |
SingleStream |
LogicalElement.getSingleStream2() |
Constructor and Description |
---|
CountElement(SingleStream singleStream,
int minCount,
int maxCount) |
LogicalElement(SingleStream singleStream1,
LogicalElement.Type type,
SingleStream singleStream2) |
Modifier and Type | Method and Description |
---|---|
static SequenceElement |
Sequence.oneOrMany(SingleStream singleStream) |
static SequenceElement |
Sequence.or(SingleStream singleStream1,
SingleStream singleStream2) |
static SequenceElement |
Sequence.zeroOrMany(SingleStream singleStream) |
static SequenceElement |
Sequence.zeroOrOne(SingleStream singleStream) |
Modifier and Type | Method and Description |
---|---|
SingleStream |
RegexElement.getSingleStream() |
SingleStream |
OrElement.getSingleStream1() |
SingleStream |
OrElement.getSingleStream2() |
Constructor and Description |
---|
OrElement(SingleStream singleStream1,
SingleStream singleStream2) |
RegexElement(SingleStream singleStream,
int minCount,
int maxCount) |
Modifier and Type | Method and Description |
---|---|
SingleStream |
SiddhiQLGrammarWalker.basicStream() |
SingleStream |
SiddhiQLGrammarWalker.itemStream() |
SingleStream |
SiddhiQLGrammarWalker.leftStream() |
SingleStream |
SiddhiQLGrammarWalker.returnQuery() |
SingleStream |
SiddhiQLGrammarWalker.rightStream() |
SingleStream |
SiddhiQLGrammarWalker.stream() |
Modifier and Type | Method and Description |
---|---|
SequenceElement |
SiddhiQLGrammarWalker.regex(SingleStream singleStream) |
Copyright © 2012. All Rights Reserved.