Uses of Class
org.apache.storm.streams.ProcessorNode
-
Uses of ProcessorNode in org.apache.storm.streams.processors
ModifierConstructorDescriptionChainedProcessorContext
(ProcessorNode processorNode, List<? extends ProcessorContext> contexts) ChainedProcessorContext
(ProcessorNode processorNode, ProcessorContext... contexts) EmittingProcessorContext
(ProcessorNode processorNode, OutputCollector collector, String outputStreamId) ForwardingProcessorContext
(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren) ModifierConstructorDescriptionForwardingProcessorContext
(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String, ProcessorNode> streamToChildren)