org.apache.tephra.persist

Class HDFSTransactionLogReaderSupplier

java.lang.Object

org.apache.tephra.persist.HDFSTransactionLogReaderSupplier

All Implemented Interfaces:

com.google.common.base.Supplier<TransactionLogReader>

public class HDFSTransactionLogReaderSupplier
extends Object
implements com.google.common.base.Supplier<TransactionLogReader>

Provides the correct version of TransactionLogReader, based on the log's version metadata, to read HDFS Transaction Logs.

Constructor Summary

Constructors

Constructor and Description
HDFSTransactionLogReaderSupplier(org.apache.hadoop.io.SequenceFile.Reader reader)

Method Summary

Methods

Modifier and Type	Method and Description
TransactionLogReader	get()

Methods inherited from class java.lang.Object

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

Constructor Detail

HDFSTransactionLogReaderSupplier

public HDFSTransactionLogReaderSupplier(org.apache.hadoop.io.SequenceFile.Reader reader)

Method Detail

get

public TransactionLogReader get()

Specified by:

get in interface com.google.common.base.Supplier<TransactionLogReader>