public class BatchSpoutExecutor.BatchSpoutEmitter extends Object implements ITridentSpout.Emitter
Constructor and Description |
---|
BatchSpoutEmitter() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Release any resources held by this emitter.
|
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 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 close()
ITridentSpout.Emitter
close
in interface ITridentSpout.Emitter
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.