backtype.storm.transactional.partitioned

Interface IPartitionedTransactionalSpout.Emitter<X>

Enclosing interface:

IPartitionedTransactionalSpout<T>

public static interface IPartitionedTransactionalSpout.Emitter<X>

Method Summary

Methods

Modifier and Type	Method and Description
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()