public interface IPartitionedTridentSpout<Partitions,Partition extends ISpoutPartition,T> extends Serializable
| Modifier and Type | Interface and Description |
|---|---|
static interface |
IPartitionedTridentSpout.Coordinator<Partitions> |
static interface |
IPartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,X> |
| Modifier and Type | Method and Description |
|---|---|
Map |
getComponentConfiguration() |
IPartitionedTridentSpout.Coordinator<Partitions> |
getCoordinator(Map conf,
TopologyContext context) |
IPartitionedTridentSpout.Emitter<Partitions,Partition,T> |
getEmitter(Map conf,
TopologyContext context) |
Fields |
getOutputFields() |
IPartitionedTridentSpout.Coordinator<Partitions> getCoordinator(Map conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,T> getEmitter(Map conf, TopologyContext context)
Map getComponentConfiguration()
Fields getOutputFields()
Copyright © 2015. All rights reserved.