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 © 2023 The Apache Software Foundation. All rights reserved.