backtype.storm.transactional.partitioned
Interface IPartitionedTransactionalSpout.Emitter<X>

Enclosing interface:
IPartitionedTransactionalSpout<T>

public static interface IPartitionedTransactionalSpout.Emitter<X>


Method Summary
 void close()
           
 void emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector 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, BatchOutputCollector 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,
                        BatchOutputCollector 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,
                        BatchOutputCollector 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()