org.apache.tephra.persist

Class HDFSTransactionLog

java.lang.Object

org.apache.tephra.persist.AbstractTransactionLog

org.apache.tephra.persist.HDFSTransactionLog

All Implemented Interfaces:

TransactionLog

public class HDFSTransactionLog
extends AbstractTransactionLog

Allows reading from and writing to a transaction write-ahead log stored in HDFS.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tephra.persist.AbstractTransactionLog

AbstractTransactionLog.Entry

Field Summary

Fields inherited from class org.apache.tephra.persist.AbstractTransactionLog

timestamp

Method Summary

Modifier and Type	Method and Description
protected TransactionLogWriter	createWriter() Returns a log writer to be used for appending any new TransactionEdit objects.
String	getName()
TransactionLogReader	getReader()

Methods inherited from class org.apache.tephra.persist.AbstractTransactionLog

append, append, close, getTimestamp, isClosed

Methods inherited from class java.lang.Object

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

Method Detail

createWriter

protected TransactionLogWriter createWriter()
                                     throws IOException

Description copied from class: AbstractTransactionLog

Returns a log writer to be used for appending any new TransactionEdit objects.

Specified by:

createWriter in class AbstractTransactionLog

Throws:

IOException

getName

public String getName()

Specified by:

getName in interface TransactionLog

Specified by:

getName in class AbstractTransactionLog

getReader

public TransactionLogReader getReader()
                               throws IOException

Specified by:

getReader in interface TransactionLog

Specified by:

getReader in class AbstractTransactionLog

Throws:

IOException