|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Emitter
public class OpaquePartitionedTransactionalSpoutExecutor.Emitter
Constructor Summary | |
---|---|
OpaquePartitionedTransactionalSpoutExecutor.Emitter(java.util.Map conf,
TopologyContext context)
|
Method Summary | |
---|---|
void |
cleanupBefore(java.math.BigInteger txid)
Any state for transactions prior to the provided transaction id can be safely cleaned up, so this method should clean up that state. |
void |
close()
Release any resources held by this emitter. |
void |
commit(TransactionAttempt attempt)
|
void |
emitBatch(TransactionAttempt tx,
java.lang.Object coordinatorMeta,
BatchOutputCollector collector)
Emit a batch for the specified transaction attempt and metadata for the transaction. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public OpaquePartitionedTransactionalSpoutExecutor.Emitter(java.util.Map conf, TopologyContext context)
Method Detail |
---|
public void emitBatch(TransactionAttempt tx, java.lang.Object coordinatorMeta, BatchOutputCollector collector)
ITransactionalSpout.Emitter
emitBatch
in interface ITransactionalSpout.Emitter
public void cleanupBefore(java.math.BigInteger txid)
ITransactionalSpout.Emitter
cleanupBefore
in interface ITransactionalSpout.Emitter
public void commit(TransactionAttempt attempt)
commit
in interface ICommitterTransactionalSpout.Emitter
public void close()
ITransactionalSpout.Emitter
close
in interface ITransactionalSpout.Emitter
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |