Package | Description |
---|---|
org.apache.storm.trident.spout | |
org.apache.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 © 2019 The Apache Software Foundation. All Rights Reserved.