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 © 2016 The Apache Software Foundation. All Rights Reserved.