org.apache.storm.kafka.spout.trident

Class KafkaTridentSpoutTransactional

java.lang.Object

org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTransactional

All Implemented Interfaces:

Serializable, IPartitionedTridentSpout, ITridentDataSource

public class KafkaTridentSpoutTransactional
extends Object
implements IPartitionedTridentSpout

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.trident.spout.IPartitionedTridentSpout

IPartitionedTridentSpout.Coordinator<Partitions>, IPartitionedTridentSpout.Emitter<Partitions,Partition extends ISpoutPartition,X>

Constructor Summary

Constructors

Constructor and Description
KafkaTridentSpoutTransactional()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	getComponentConfiguration()
IPartitionedTridentSpout.Coordinator	getCoordinator(Map conf, TopologyContext context)
IPartitionedTridentSpout.Emitter	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

KafkaTridentSpoutTransactional

public KafkaTridentSpoutTransactional()

Method Detail

getCoordinator

public IPartitionedTridentSpout.Coordinator getCoordinator(Map conf,
                                                           TopologyContext context)

Specified by:

getCoordinator in interface IPartitionedTridentSpout

getEmitter

public IPartitionedTridentSpout.Emitter getEmitter(Map conf,
                                                   TopologyContext context)

Specified by:

getEmitter in interface IPartitionedTridentSpout

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface IPartitionedTridentSpout

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface IPartitionedTridentSpout