Package | Description |
---|---|
org.apache.storm.streams.processors |
Modifier and Type | Class and Description |
---|---|
class |
ChainedProcessorContext<T>
A composite context that holds a chain of
ProcessorContext . |
class |
EmittingProcessorContext<T>
A context that emits the results to downstream processors which are in another bolt.
|
class |
ForwardingProcessorContext<T>
A context that emits the results to downstream processors which are in the same bolt.
|
Modifier and Type | Method and Description |
---|---|
void |
Processor.init(ProcessorContext context)
Initializes the processor.
|
Constructor and Description |
---|
ChainedProcessorContext(ProcessorNode processorNode,
ProcessorContext... contexts) |
Constructor and Description |
---|
ChainedProcessorContext(ProcessorNode processorNode,
List<? extends ProcessorContext> contexts) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.