| Package | Description |
|---|---|
| storm.trident.spout | |
| storm.trident.testing |
| Modifier and Type | Class and Description |
|---|---|
class |
OpaquePartitionedTridentSpoutExecutor.Emitter |
| Modifier and Type | Method and Description |
|---|---|
ICommitterTridentSpout.Emitter |
OpaquePartitionedTridentSpoutExecutor.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
ICommitterTridentSpout.Emitter |
ICommitterTridentSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
| Modifier and Type | Method and Description |
|---|---|
ICommitterTridentSpout.Emitter |
FeederCommitterBatchSpout.getEmitter(String txStateId,
Map conf,
TopologyContext context) |
Copyright © 2015. All rights reserved.