org.apache.storm.eventhubs.trident

Class TransactionalTridentEventHubSpout

java.lang.Object

org.apache.storm.eventhubs.trident.TransactionalTridentEventHubSpout

All Implemented Interfaces:

Serializable, IPartitionedTridentSpout<Partitions,Partition,Map>, ITridentDataSource

public class TransactionalTridentEventHubSpout
extends Object
implements IPartitionedTridentSpout<Partitions,Partition,Map>

Transactional Trident EventHub Spout

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
TransactionalTridentEventHubSpout(EventHubSpoutConfig config)

Method Summary

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

TransactionalTridentEventHubSpout

public TransactionalTridentEventHubSpout(EventHubSpoutConfig config)

Method Detail

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface IPartitionedTridentSpout<Partitions,Partition,Map>

getCoordinator

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

Specified by:

getCoordinator in interface IPartitionedTridentSpout<Partitions,Partition,Map>

getEmitter

public IPartitionedTridentSpout.Emitter<Partitions,Partition,Map> getEmitter(Map conf,
                                                                             TopologyContext context)

Specified by:

getEmitter in interface IPartitionedTridentSpout<Partitions,Partition,Map>

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface IPartitionedTridentSpout<Partitions,Partition,Map>