public class JoinStreamRuntime extends Object implements StreamRuntime
Constructor and Description |
---|
JoinStreamRuntime(SiddhiQueryContext siddhiQueryContext,
MetaStateEvent metaStateEvent) |
Modifier and Type | Method and Description |
---|---|
void |
addRuntime(SingleStreamRuntime singleStreamRuntime) |
MetaComplexEvent |
getMetaComplexEvent() |
ProcessingMode |
getProcessingMode() |
List<SingleStreamRuntime> |
getSingleStreamRuntimes() |
void |
setCommonProcessor(Processor commonProcessor) |
public JoinStreamRuntime(SiddhiQueryContext siddhiQueryContext, MetaStateEvent metaStateEvent)
public void addRuntime(SingleStreamRuntime singleStreamRuntime)
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
Copyright © 2019. All rights reserved.