Package | Description |
---|---|
io.siddhi.core.query.input | |
io.siddhi.core.query.input.stream.state | |
io.siddhi.core.query.input.stream.state.runtime |
Modifier and Type | Field and Description |
---|---|
protected List<PreStateProcessor> |
ProcessStreamReceiver.stateProcessors |
Modifier and Type | Method and Description |
---|---|
void |
ProcessStreamReceiver.addStatefulProcessor(PreStateProcessor stateProcessor) |
Modifier and Type | Class and Description |
---|---|
class |
AbsentLogicalPreStateProcessor
Logical not processor.
|
class |
AbsentStreamPreStateProcessor
Pre processor of not operator.
|
class |
CountPreStateProcessor
Created on 1/6/15.
|
class |
LogicalPreStateProcessor
Logical and & or processor.
|
class |
StreamPreStateProcessor
The processor the gets executes before checking state conditions.
|
Modifier and Type | Field and Description |
---|---|
protected PreStateProcessor |
StreamPostStateProcessor.nextEveryStatePreProcessor |
protected PreStateProcessor |
StreamPostStateProcessor.nextStatePreProcessor |
protected PreStateProcessor |
StreamPreStateProcessor.withinEveryPreStateProcessor |
Modifier and Type | Method and Description |
---|---|
PreStateProcessor |
StreamPostStateProcessor.getNextEveryStatePreProcessor() |
PreStateProcessor |
StreamPostStateProcessor.getNextStatePreProcessor() |
PreStateProcessor |
StreamPostStateProcessor.getThisStatePreProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
LogicalPostStateProcessor.setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor) |
void |
PostStateProcessor.setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor) |
void |
StreamPostStateProcessor.setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor) |
void |
LogicalPostStateProcessor.setNextStatePreProcessor(PreStateProcessor preStateProcessor) |
void |
CountPostStateProcessor.setNextStatePreProcessor(PreStateProcessor preStateProcessor) |
void |
PostStateProcessor.setNextStatePreProcessor(PreStateProcessor nextStatePreProcessor) |
void |
StreamPostStateProcessor.setNextStatePreProcessor(PreStateProcessor preStateProcessor) |
void |
StreamPreStateProcessor.setWithinEveryPreStateProcessor(PreStateProcessor withinEveryPreStateProcessor) |
void |
PreStateProcessor.setWithinEveryPreStateProcessor(PreStateProcessor withinEveryPreStateProcessor) |
Modifier and Type | Method and Description |
---|---|
void |
StateStreamRuntime.setStartupPreStateProcessors(List<PreStateProcessor> startupPreStateProcessors) |
Modifier and Type | Field and Description |
---|---|
protected PreStateProcessor |
StreamInnerStateRuntime.firstProcessor |
Modifier and Type | Method and Description |
---|---|
PreStateProcessor |
StreamInnerStateRuntime.getFirstProcessor() |
PreStateProcessor |
InnerStateRuntime.getFirstProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
StreamInnerStateRuntime.setFirstProcessor(PreStateProcessor firstProcessor) |
void |
InnerStateRuntime.setFirstProcessor(PreStateProcessor firstProcessor) |
Copyright © 2019. All rights reserved.