Package | Description |
---|---|
io.siddhi.core.query.input | |
io.siddhi.core.query.input.stream.single | |
io.siddhi.core.query.input.stream.state.receiver | |
io.siddhi.core.util.parser |
Modifier and Type | Class and Description |
---|---|
class |
MultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events to be fed into multi
stream processors which consume multiple streams.
|
class |
SingleProcessStreamReceiver
Implementation of {StreamJunction.Receiver} to receive events to be fed into
single stream stateless queries(Filter).
|
class |
StateMultiProcessStreamReceiver
Implementation of {StreamJunction.Receiver} to receive events to be fed into
multi stream stateful queries.
|
Modifier and Type | Method and Description |
---|---|
ProcessStreamReceiver |
SingleStreamRuntime.getProcessStreamReceiver() |
Constructor and Description |
---|
SingleStreamRuntime(ProcessStreamReceiver processStreamReceiver,
Processor processorChain,
ProcessingMode overallProcessingMode,
MetaComplexEvent metaComplexEvent) |
Modifier and Type | Class and Description |
---|---|
class |
PatternMultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into pattern queries
with multiple streams.
|
class |
PatternSingleProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into pattern queries
with single stream.
|
class |
SequenceMultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into sequence queries
with multiple streams.
|
class |
SequenceSingleProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into sequence queries
with single stream.
|
Modifier and Type | Method and Description |
---|---|
static SingleStreamRuntime |
SingleInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.SingleInputStream inputStream,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
Map<String,Table> tableMap,
MetaComplexEvent metaComplexEvent,
ProcessStreamReceiver processStreamReceiver,
boolean supportsBatchProcessing,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
Parse single InputStream and return SingleStreamRuntime
|
Copyright © 2019. All rights reserved.