org.apache.storm.transactional.partitioned

Interface IPartitionedTransactionalSpout.Emitter<X>

Enclosing interface:

IPartitionedTransactionalSpout<T>

public static interface IPartitionedTransactionalSpout.Emitter<X>

Method Summary

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()