Uses of Class
org.apache.storm.streams.ProcessorNode
-
Packages that use ProcessorNode Package Description org.apache.storm.streams.processors -
-
Uses of ProcessorNode in org.apache.storm.streams.processors
Constructors in org.apache.storm.streams.processors with parameters of type ProcessorNode Constructor Description ChainedProcessorContext(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)
Constructor parameters in org.apache.storm.streams.processors with type arguments of type ProcessorNode Constructor Description ForwardingProcessorContext(ProcessorNode processorNode, org.apache.storm.shade.com.google.common.collect.Multimap<String,ProcessorNode> streamToChildren)
-