public class StreamInnerStateRuntime extends Object implements InnerStateRuntime
Modifier and Type | Field and Description |
---|---|
protected PreStateProcessor |
firstProcessor |
protected PostStateProcessor |
lastProcessor |
protected List<SingleStreamRuntime> |
singleStreamRuntimeList |
protected io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type |
stateType |
Constructor and Description |
---|
StreamInnerStateRuntime(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType) |
Modifier and Type | Method and Description |
---|---|
void |
addStreamRuntime(SingleStreamRuntime singleStreamRuntime) |
PreStateProcessor |
getFirstProcessor() |
PostStateProcessor |
getLastProcessor() |
List<SingleStreamRuntime> |
getSingleStreamRuntimeList() |
io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type |
getStateType() |
void |
init() |
void |
reset() |
void |
setFirstProcessor(PreStateProcessor firstProcessor) |
void |
setLastProcessor(PostStateProcessor lastProcessor) |
void |
setQuerySelector(Processor commonProcessor) |
void |
setup() |
void |
update() |
protected List<SingleStreamRuntime> singleStreamRuntimeList
protected PreStateProcessor firstProcessor
protected PostStateProcessor lastProcessor
protected io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType
public StreamInnerStateRuntime(io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type stateType)
public PreStateProcessor getFirstProcessor()
getFirstProcessor
in interface InnerStateRuntime
public void setFirstProcessor(PreStateProcessor firstProcessor)
setFirstProcessor
in interface InnerStateRuntime
public PostStateProcessor getLastProcessor()
getLastProcessor
in interface InnerStateRuntime
public void setLastProcessor(PostStateProcessor lastProcessor)
setLastProcessor
in interface InnerStateRuntime
public List<SingleStreamRuntime> getSingleStreamRuntimeList()
getSingleStreamRuntimeList
in interface InnerStateRuntime
public void addStreamRuntime(SingleStreamRuntime singleStreamRuntime)
addStreamRuntime
in interface InnerStateRuntime
public void setQuerySelector(Processor commonProcessor)
setQuerySelector
in interface InnerStateRuntime
public io.siddhi.query.api.execution.query.input.stream.StateInputStream.Type getStateType()
public void setup()
setup
in interface InnerStateRuntime
public void init()
init
in interface InnerStateRuntime
public void reset()
reset
in interface InnerStateRuntime
public void update()
update
in interface InnerStateRuntime
Copyright © 2019. All rights reserved.