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() |
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 MetaComplexEvent getMetaComplexEvent()
getMetaComplexEvent
in interface StreamRuntime
public ProcessingMode getProcessingMode()
getProcessingMode
in interface StreamRuntime
Copyright © 2019. All rights reserved.