public class LogicalPostStateProcessor extends StreamPostStateProcessor
Modifier and Type | Field and Description |
---|---|
protected io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type |
type |
callbackPreStateProcessor, isEventReturned, nextEveryStatePreProcessor, nextProcessor, nextStatePreProcessor, stateId, thisStatePreProcessor
Constructor and Description |
---|
LogicalPostStateProcessor(io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type) |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type |
getType() |
protected void |
process(StateEvent stateEvent,
ComplexEventChunk complexEventChunk) |
void |
setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor) |
void |
setNextProcessor(Processor nextProcessor)
Set next processor element in processor chain
|
void |
setNextStatePreProcessor(PreStateProcessor preStateProcessor) |
void |
setPartnerPostStateProcessor(LogicalPostStateProcessor partnerPostStateProcessor) |
void |
setPartnerPreStateProcessor(LogicalPreStateProcessor partnerPreStateProcessor) |
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
clearProcessedEvent, getNextEveryStatePreProcessor, getNextProcessor, getNextStatePreProcessor, getStateId, getThisStatePreProcessor, isEventReturned, process, process, setCallbackPreStateProcessor, setStateId, setThisStatePreProcessor
protected io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type
public LogicalPostStateProcessor(io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type type)
public io.siddhi.query.api.execution.query.input.state.LogicalStateElement.Type getType()
protected void process(StateEvent stateEvent, ComplexEventChunk complexEventChunk)
process
in class StreamPostStateProcessor
public void setPartnerPreStateProcessor(LogicalPreStateProcessor partnerPreStateProcessor)
public void setPartnerPostStateProcessor(LogicalPostStateProcessor partnerPostStateProcessor)
public void setNextProcessor(Processor nextProcessor)
setNextProcessor
in interface Processor
setNextProcessor
in class StreamPostStateProcessor
nextProcessor
- Processor to be set as next element of processor chainpublic void setToLast(Processor processor)
setToLast
in interface Processor
setToLast
in class StreamPostStateProcessor
processor
- Last processor in the chainpublic void setNextStatePreProcessor(PreStateProcessor preStateProcessor)
setNextStatePreProcessor
in interface PostStateProcessor
setNextStatePreProcessor
in class StreamPostStateProcessor
public void setNextEveryStatePreProcessor(PreStateProcessor nextEveryStatePreProcessor)
setNextEveryStatePreProcessor
in interface PostStateProcessor
setNextEveryStatePreProcessor
in class StreamPostStateProcessor
Copyright © 2019. All rights reserved.