public static interface IPartitionedTransactionalSpout.Emitter<X>
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.
|
X emitPartitionBatchNew(TransactionAttempt tx, BatchOutputCollector collector, int partition, X lastPartitionMeta)
void emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector collector, int partition, X partitionMeta)
void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.