public class OpaquePartitionedTridentSpoutExecutor.Emitter extends Object implements ICommitterTridentSpout.Emitter
Constructor and Description |
---|
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 Emitter(String txStateId, Map conf, TopologyContext context)
public void emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
ITridentSpout.Emitter
emitBatch
in interface ITridentSpout.Emitter
public void success(TransactionAttempt tx)
ITridentSpout.Emitter
success
in interface ITridentSpout.Emitter
public void commit(TransactionAttempt attempt)
commit
in interface ICommitterTridentSpout.Emitter
public void close()
ITridentSpout.Emitter
close
in interface ITridentSpout.Emitter
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.