public class SingleStreamRuntime extends Object implements StreamRuntime
Constructor and Description |
---|
SingleStreamRuntime(ProcessStreamReceiver processStreamReceiver,
Processor processorChain,
ProcessingMode overallProcessingMode,
MetaComplexEvent metaComplexEvent) |
Modifier and Type | Method and Description |
---|---|
MetaComplexEvent |
getMetaComplexEvent() |
ProcessingMode |
getProcessingMode() |
Processor |
getProcessorChain() |
ProcessStreamReceiver |
getProcessStreamReceiver() |
QuerySelector |
getQuerySelector() |
List<SingleStreamRuntime> |
getSingleStreamRuntimes() |
void |
setCommonProcessor(Processor commonProcessor) |
void |
setProcessorChain(Processor processorChain) |
public SingleStreamRuntime(ProcessStreamReceiver processStreamReceiver, Processor processorChain, ProcessingMode overallProcessingMode, MetaComplexEvent metaComplexEvent)
public Processor getProcessorChain()
public void setProcessorChain(Processor processorChain)
public ProcessStreamReceiver getProcessStreamReceiver()
public List<SingleStreamRuntime> getSingleStreamRuntimes()
getSingleStreamRuntimes
in interface StreamRuntime
public void setCommonProcessor(Processor commonProcessor)
setCommonProcessor
in interface StreamRuntime
public QuerySelector getQuerySelector()
getQuerySelector
in interface StreamRuntime
public MetaComplexEvent getMetaComplexEvent()
getMetaComplexEvent
in interface StreamRuntime
public ProcessingMode getProcessingMode()
getProcessingMode
in interface StreamRuntime
Copyright © 2019. All rights reserved.