backtype.storm.transactional.partitioned

Interface IOpaquePartitionedTransactionalSpout.Emitter<X>

Enclosing interface:

IOpaquePartitionedTransactionalSpout<T>

public static interface IOpaquePartitionedTransactionalSpout.Emitter<X>

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
X	emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector collector, int partition, X lastPartitionMeta) Emit a batch of tuples for a partition/transaction.
int	numPartitions()

Method Detail

emitPartitionBatch

X emitPartitionBatch(TransactionAttempt tx,
                   BatchOutputCollector collector,
                   int partition,
                   X lastPartitionMeta)

Emit a batch of tuples for a partition/transaction. Return the metadata describing this batch that will be used as lastPartitionMeta for defining the parameters of the next batch.

numPartitions

int numPartitions()

close

void close()