Package | Description |
---|---|
org.apache.storm.streams.processors |
Constructor and 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 and Description |
---|
ForwardingProcessorContext(ProcessorNode processorNode,
org.apache.storm.shade.com.google.common.collect.Multimap<String,ProcessorNode> streamToChildren) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.