| Package | Description |
|---|---|
| storm.trident.planner | |
| storm.trident.planner.processor |
| Modifier and Type | Field and Description |
|---|---|
TridentProcessor |
ProcessorNode.processor |
| Modifier and Type | Method and Description |
|---|---|
void |
SubtopologyBolt.InitialReceiver.addReceiver(TridentProcessor p) |
| Constructor and Description |
|---|
ProcessorNode(String streamId,
String name,
Fields allOutputFields,
Fields selfOutFields,
TridentProcessor processor) |
| Modifier and Type | Class and Description |
|---|---|
class |
AggregateProcessor |
class |
EachProcessor |
class |
MultiReducerProcessor |
class |
PartitionPersistProcessor |
class |
ProjectedProcessor |
class |
StateQueryProcessor |
Copyright © 2015. All rights reserved.