org.apache.flume.channel
Class MemoryChannel.MemTransaction

java.lang.Object
  org.apache.flume.channel.MemoryChannel.MemTransaction

All Implemented Interfaces:

Transaction

Enclosing class:

MemoryChannel

public class MemoryChannel.MemTransaction
extends Object
implements Transaction

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flume.Transaction

Transaction.TransactionState

Constructor Summary

MemoryChannel.MemTransaction()

Method Summary

void	begin() Starts a transaction boundary for the current channel operation.
void	close() Ends a transaction boundary for the current channel operation.
void	commit() Indicates that the transaction can be successfully committed.
Transaction.TransactionState	getState()
protected int	lastTakeStamp()
protected void	logPut(org.apache.flume.channel.MemoryChannel.StampedEvent e, int stamp)
protected void	logTake(org.apache.flume.channel.MemoryChannel.StampedEvent e, int stamp)
protected org.apache.flume.channel.MemoryChannel.StampedEvent	removePut()
protected org.apache.flume.channel.MemoryChannel.StampedEvent	removeTake()
void	rollback() Indicates that the transaction can must be aborted.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MemoryChannel.MemTransaction

public MemoryChannel.MemTransaction()

Method Detail

begin

public void begin()

Description copied from interface: Transaction

Starts a transaction boundary for the current channel operation. If a transaction is already in progress, this method will join that transaction using reference counting.

Note: For every invocation of this method there must be a corresponding invocation of Transaction.close() method. Failure to ensure this can lead to dangling transactions and unpredictable results.

Specified by:

begin in interface Transaction

commit

public void commit()

Description copied from interface: Transaction

Indicates that the transaction can be successfully committed. It is required that a transaction be in progress when this method is invoked.

Specified by:

commit in interface Transaction

rollback

public void rollback()

Description copied from interface: Transaction

Indicates that the transaction can must be aborted. It is required that a transaction be in progress when this method is invoked.

Specified by:

rollback in interface Transaction

close

public void close()

Description copied from interface: Transaction

Ends a transaction boundary for the current channel operation. If a transaction is already in progress, this method will join that transaction using reference counting. The transaction is completed only if there are no more references left for this transaction.

Note: For every invocation of this method there must be a corresponding invocation of Transaction.begin() method. Failure to ensure this can lead to dangling transactions and unpredictable results.

Specified by:

close in interface Transaction

getState

public Transaction.TransactionState getState()

lastTakeStamp

protected int lastTakeStamp()

logPut

protected void logPut(org.apache.flume.channel.MemoryChannel.StampedEvent e,
                      int stamp)

logTake

protected void logTake(org.apache.flume.channel.MemoryChannel.StampedEvent e,
                       int stamp)

removePut

protected org.apache.flume.channel.MemoryChannel.StampedEvent removePut()

removeTake

protected org.apache.flume.channel.MemoryChannel.StampedEvent removeTake()