| Package | Description |
|---|---|
| org.apache.storm.trident.planner | |
| org.apache.storm.trident.spout | |
| org.apache.storm.trident.topology |
| Modifier and Type | Class and Description |
|---|---|
class |
SubtopologyBolt
A Bolt that does processing for a subsection of the complete graph.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TridentSpoutExecutor |
| Modifier and Type | Method and Description |
|---|---|
BoltDeclarer |
TridentTopologyBuilder.setBolt(String id,
ITridentBatchBolt bolt,
Integer parallelism,
Set<String> committerBatches,
Map<String,String> batchGroups) |
| Constructor and Description |
|---|
TridentBoltExecutor(ITridentBatchBolt bolt,
Map<GlobalStreamId,String> batchGroupIds,
Map<String,TridentBoltExecutor.CoordSpec> coordinationSpecs) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.