public class OpaquePartitionedTridentSpoutExecutor.Emitter extends Object implements ICommitterTridentSpout.Emitter
| Constructor and Description |
|---|
OpaquePartitionedTridentSpoutExecutor.Emitter(String txStateId,
Map conf,
TopologyContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Release any resources held by this emitter.
|
void |
commit(TransactionAttempt attempt) |
void |
emitBatch(TransactionAttempt tx,
Object coordinatorMeta,
TridentCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction.
|
void |
success(TransactionAttempt tx)
This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
|
public OpaquePartitionedTridentSpoutExecutor.Emitter(String txStateId, Map conf, TopologyContext context)
public void emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
ITridentSpout.EmitteremitBatch in interface ITridentSpout.Emitterpublic void success(TransactionAttempt tx)
ITridentSpout.Emittersuccess in interface ITridentSpout.Emitterpublic void commit(TransactionAttempt attempt)
commit in interface ICommitterTridentSpout.Emitterpublic void close()
ITridentSpout.Emitterclose in interface ITridentSpout.EmitterCopyright © 2015. All rights reserved.