public abstract class QueryFactory extends Object
Constructor and Description |
---|
QueryFactory() |
Modifier and Type | Method and Description |
---|---|
static Query |
createQuery() |
static StreamDefinition |
createStreamDefinition() |
static SingleStream |
inputStream(String streamId) |
static SingleStream |
inputStream(String streamReferenceId,
String streamId) |
static Stream |
joinStream(SingleStream leftStream,
JoinStream.Type type,
SingleStream rightStream) |
static Stream |
joinStream(SingleStream leftStream,
JoinStream.Type type,
SingleStream rightStream,
Condition onCompare) |
static Stream |
joinStream(SingleStream leftStream,
JoinStream.Type type,
SingleStream rightStream,
Condition onCompare,
JoinStream.EventTrigger trigger) |
static Projector |
outputProjector() |
static PatternStream |
patternStream(PatternElement patternElement) |
static SequenceStream |
sequenceStream(SequenceElement sequenceElement) |
public static Query createQuery()
public static StreamDefinition createStreamDefinition()
public static SingleStream inputStream(String streamId)
public static Projector outputProjector()
public static Stream joinStream(SingleStream leftStream, JoinStream.Type type, SingleStream rightStream, Condition onCompare)
public static Stream joinStream(SingleStream leftStream, JoinStream.Type type, SingleStream rightStream)
public static Stream joinStream(SingleStream leftStream, JoinStream.Type type, SingleStream rightStream, Condition onCompare, JoinStream.EventTrigger trigger)
public static SingleStream inputStream(String streamReferenceId, String streamId)
public static PatternStream patternStream(PatternElement patternElement)
public static SequenceStream sequenceStream(SequenceElement sequenceElement)
Copyright © 2012. All Rights Reserved.