public class StateStreamRuntime extends Object implements StreamRuntime
StateEvent
.Constructor and Description |
---|
StateStreamRuntime(SiddhiQueryContext siddhiQueryContext,
MetaStateEvent metaStateEvent) |
Modifier and Type | Method and Description |
---|---|
InnerStateRuntime |
getInnerStateRuntime() |
MetaComplexEvent |
getMetaComplexEvent() |
ProcessingMode |
getProcessingMode() |
List<SingleStreamRuntime> |
getSingleStreamRuntimes() |
void |
initPartition() |
void |
resetAndUpdate() |
void |
setCommonProcessor(Processor commonProcessor) |
void |
setInnerStateRuntime(InnerStateRuntime innerStateRuntime) |
void |
setStartupPreStateProcessors(List<PreStateProcessor> startupPreStateProcessors) |
public StateStreamRuntime(SiddhiQueryContext siddhiQueryContext, MetaStateEvent metaStateEvent)
public List<SingleStreamRuntime> getSingleStreamRuntimes()
getSingleStreamRuntimes
in interface StreamRuntime
public void setCommonProcessor(Processor commonProcessor)
setCommonProcessor
in interface StreamRuntime
public MetaComplexEvent getMetaComplexEvent()
getMetaComplexEvent
in interface StreamRuntime
public ProcessingMode getProcessingMode()
getProcessingMode
in interface StreamRuntime
public InnerStateRuntime getInnerStateRuntime()
public void setInnerStateRuntime(InnerStateRuntime innerStateRuntime)
public void resetAndUpdate()
public void setStartupPreStateProcessors(List<PreStateProcessor> startupPreStateProcessors)
public void initPartition()
Copyright © 2019. All rights reserved.