public class NextInnerStateRuntime extends StreamInnerStateRuntime
firstProcessor, lastProcessor, singleStreamRuntimeList, stateType
Constructor and Description |
---|
NextInnerStateRuntime(InnerStateRuntime currentInnerStateRuntime,
InnerStateRuntime nextInnerStateRuntime,
io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
Modifier and Type | Method and Description |
---|---|
void |
init() |
void |
reset() |
void |
setQuerySelector(Processor commonProcessor) |
void |
setup() |
void |
update() |
addStreamRuntime, getFirstProcessor, getLastProcessor, getSingleStreamRuntimeList, getStateType, setFirstProcessor, setLastProcessor
public NextInnerStateRuntime(InnerStateRuntime currentInnerStateRuntime, InnerStateRuntime nextInnerStateRuntime, io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
public void setQuerySelector(Processor commonProcessor)
setQuerySelector
in interface InnerStateRuntime
setQuerySelector
in class StreamInnerStateRuntime
public void setup()
setup
in interface InnerStateRuntime
setup
in class StreamInnerStateRuntime
public void init()
init
in interface InnerStateRuntime
init
in class StreamInnerStateRuntime
public void reset()
reset
in interface InnerStateRuntime
reset
in class StreamInnerStateRuntime
public void update()
update
in interface InnerStateRuntime
update
in class StreamInnerStateRuntime
Copyright © 2021. All rights reserved.