storm.trident.spout
Interface IPartitionedTridentSpout.Emitter<X>
- Enclosing interface:
- IPartitionedTridentSpout<T>
public static interface IPartitionedTridentSpout.Emitter<X>
emitPartitionBatchNew
X emitPartitionBatchNew(TransactionAttempt tx,
TridentCollector 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,
TridentCollector 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()