backtype.storm.topology.base

Class BasePartitionedTransactionalSpout<T>

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BasePartitionedTransactionalSpout<T>

All Implemented Interfaces:

IComponent, IPartitionedTransactionalSpout<T>, Serializable

public abstract class BasePartitionedTransactionalSpout<T>
extends BaseComponent
implements IPartitionedTransactionalSpout<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout

IPartitionedTransactionalSpout.Coordinator, IPartitionedTransactionalSpout.Emitter<X>

Constructor Summary

Constructors

Constructor and Description
BasePartitionedTransactionalSpout()

Method Summary

Methods inherited from class backtype.storm.topology.base.BaseComponent

getComponentConfiguration

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout

getCoordinator, getEmitter

Methods inherited from interface backtype.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Constructor Detail

BasePartitionedTransactionalSpout

public BasePartitionedTransactionalSpout()