org.apache.storm.topology.base

Class BaseOpaquePartitionedTransactionalSpout<T>

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseOpaquePartitionedTransactionalSpout<T>

All Implemented Interfaces:

Serializable, IComponent, IOpaquePartitionedTransactionalSpout<T>

public abstract class BaseOpaquePartitionedTransactionalSpout<T>
extends BaseComponent
implements IOpaquePartitionedTransactionalSpout<T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout

IOpaquePartitionedTransactionalSpout.Coordinator, IOpaquePartitionedTransactionalSpout.Emitter<X>

Constructor Summary

Constructors

Constructor and Description
BaseOpaquePartitionedTransactionalSpout()

Method Summary

Methods inherited from class org.apache.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 org.apache.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout

getCoordinator, getEmitter

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Constructor Detail

BaseOpaquePartitionedTransactionalSpout

public BaseOpaquePartitionedTransactionalSpout()