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() |
QuerySelector |
getQuerySelector() |
List<SingleStreamRuntime> |
getSingleStreamRuntimes() |
void |
setCommonProcessor(Processor commonProcessor) |
void |
setQuerySelector(QuerySelector querySelector) |
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 QuerySelector getQuerySelector()
getQuerySelector
in interface StreamRuntime
public void setQuerySelector(QuerySelector querySelector)
public ProcessingMode getProcessingMode()
getProcessingMode
in interface StreamRuntime
Copyright © 2021. All rights reserved.