public class EveryInnerStateRuntime extends StreamInnerStateRuntime
firstProcessor, lastProcessor, singleStreamRuntimeList, stateType
Constructor and Description |
---|
EveryInnerStateRuntime(InnerStateRuntime innerStateRuntime,
io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
Modifier and Type | Method and Description |
---|---|
void |
init() |
void |
setQuerySelector(Processor commonProcessor) |
void |
setup() |
addStreamRuntime, getFirstProcessor, getLastProcessor, getSingleStreamRuntimeList, getStateType, reset, setFirstProcessor, setLastProcessor, update
public EveryInnerStateRuntime(InnerStateRuntime innerStateRuntime, 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
Copyright © 2019. All rights reserved.