storm.trident.spout

Interface ITridentSpout<T>

All Superinterfaces:

Serializable

All Known Subinterfaces:

ICommitterTridentSpout<X>

All Known Implementing Classes:

BatchSpoutExecutor, FeederBatchSpout, FeederCommitterBatchSpout, OpaquePartitionedTridentSpoutExecutor, PartitionedTridentSpoutExecutor, RichSpoutBatchExecutor

public interface ITridentSpout<T>
extends Serializable

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ITridentSpout.BatchCoordinator<X>
static interface	ITridentSpout.Emitter<X>

Method Summary

Methods

Modifier and Type	Method and Description
Map	getComponentConfiguration()
ITridentSpout.BatchCoordinator<T>	getCoordinator(String txStateId, Map conf, TopologyContext context) The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit.
ITridentSpout.Emitter<T>	getEmitter(String txStateId, Map conf, TopologyContext context) The emitter for a TransactionalSpout runs as many tasks across the cluster.
Fields	getOutputFields()

Method Detail

getCoordinator

ITridentSpout.BatchCoordinator<T> getCoordinator(String txStateId,
                                               Map conf,
                                               TopologyContext context)

The coordinator for a TransactionalSpout runs in a single thread and indicates when batches of tuples should be emitted and when transactions should commit. The Coordinator that you provide in a TransactionalSpout provides metadata for each transaction so that the transactions can be replayed.

getEmitter

ITridentSpout.Emitter<T> getEmitter(String txStateId,
                                  Map conf,
                                  TopologyContext context)

The emitter for a TransactionalSpout runs as many tasks across the cluster. Emitters are responsible for emitting batches of tuples for a transaction and must ensure that the same batch of tuples is always emitted for the same transaction id.

getComponentConfiguration

Map getComponentConfiguration()

getOutputFields

Fields getOutputFields()