storm.kafka.trident
Class OpaqueTridentKafkaSpout

java.lang.Object
  extended by storm.kafka.trident.OpaqueTridentKafkaSpout
All Implemented Interfaces:
Serializable, IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>

public class OpaqueTridentKafkaSpout
extends Object
implements IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>

See Also:
Serialized Form

Nested Class Summary
 
Nested classes/interfaces inherited from interface storm.trident.spout.IOpaquePartitionedTridentSpout
IOpaquePartitionedTridentSpout.Coordinator<Partitions>, IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,M>
 
Constructor Summary
OpaqueTridentKafkaSpout(TridentKafkaConfig config)
           
 
Method Summary
 Map<String,Object> getComponentConfiguration()
           
 IOpaquePartitionedTridentSpout.Coordinator getCoordinator(Map conf, TopologyContext tc)
           
 IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> getEmitter(Map conf, TopologyContext context)
           
 Fields getOutputFields()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

OpaqueTridentKafkaSpout

public OpaqueTridentKafkaSpout(TridentKafkaConfig config)
Method Detail

getEmitter

public IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> getEmitter(Map conf,
                                                                                                   TopologyContext context)
Specified by:
getEmitter in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>

getCoordinator

public IOpaquePartitionedTridentSpout.Coordinator getCoordinator(Map conf,
                                                                 TopologyContext tc)
Specified by:
getCoordinator in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>

getOutputFields

public Fields getOutputFields()
Specified by:
getOutputFields in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()
Specified by:
getComponentConfiguration in interface IOpaquePartitionedTridentSpout<GlobalPartitionInformation,Partition,Map>


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.