storm.trident.spout
Interface IPartitionedTridentSpout.Emitter<X>

Enclosing interface:
IPartitionedTridentSpout<T>

public static interface IPartitionedTridentSpout.Emitter<X>


Method Summary
 void close()
           
 void emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, int partition, X partitionMeta)
          Emit a batch of tuples for a partition/transaction that has been emitted before, using the metadata created when it was first emitted.
 X emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, int partition, X lastPartitionMeta)
          Emit a batch of tuples for a partition/transaction that's never been emitted before.
 

Method Detail

emitPartitionBatchNew

X emitPartitionBatchNew(TransactionAttempt tx,
                        TridentCollector collector,
                        int partition,
                        X lastPartitionMeta)
Emit a batch of tuples for a partition/transaction that's never been emitted before. Return the metadata that can be used to reconstruct this partition/batch in the future.


emitPartitionBatch

void emitPartitionBatch(TransactionAttempt tx,
                        TridentCollector collector,
                        int partition,
                        X partitionMeta)
Emit a batch of tuples for a partition/transaction that has been emitted before, using the metadata created when it was first emitted.


close

void close()