backtype.storm.transactional.partitioned
Interface IOpaquePartitionedTransactionalSpout.Emitter<X>
- Enclosing interface:
- IOpaquePartitionedTransactionalSpout<T>
public static interface IOpaquePartitionedTransactionalSpout.Emitter<X>
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()