public class HdfsTransactionLog extends TransactionLog
Modifier and Type | Class and Description |
---|---|
class |
HdfsTransactionLog.HDFSLogReader
Deprecated.
|
class |
HdfsTransactionLog.HDFSReverseReader
Deprecated.
|
class |
HdfsTransactionLog.HDFSSortedLogReader
Deprecated.
|
TransactionLog.FSReverseReader, TransactionLog.LogCodec, TransactionLog.LogReader, TransactionLog.ReverseReader, TransactionLog.SortedLogReader
deleteOnClose, END_MESSAGE
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
|
void |
closeOutput()
Deprecated.
Move to a read-only state, closing and releasing resources while keeping the log available for reads
|
boolean |
endsWithCommit()
Deprecated.
|
void |
finish(UpdateLog.SyncLevel syncLevel)
Deprecated.
|
long |
getLogSize()
Deprecated.
|
TransactionLog.LogReader |
getReader(long startingPos)
Deprecated.
Returns a reader that can be used while a log is still in use.
|
TransactionLog.ReverseReader |
getReverseReader()
Deprecated.
Returns a single threaded reverse reader
|
TransactionLog.LogReader |
getSortedReader(long startingPos)
Deprecated.
|
Object |
lookup(long pos)
Deprecated.
|
String |
toString()
Deprecated.
|
long |
writeCommit(CommitUpdateCommand cmd)
Deprecated.
|
addGlobalStrings, checkWriteHeader, decref, endRecord, forceClose, getLogSizeFromStream, incref, numRecords, position, try_incref, write, write, writeData, writeDelete, writeDeleteByQuery, writeLogHeader
public boolean endsWithCommit() throws IOException
endsWithCommit
in class TransactionLog
IOException
public long writeCommit(CommitUpdateCommand cmd)
writeCommit
in class TransactionLog
public Object lookup(long pos)
lookup
in class TransactionLog
public void closeOutput()
TransactionLog
closeOutput
in class TransactionLog
public long getLogSize()
getLogSize
in class TransactionLog
public void finish(UpdateLog.SyncLevel syncLevel)
finish
in class TransactionLog
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class TransactionLog
public String toString()
toString
in class TransactionLog
public TransactionLog.LogReader getReader(long startingPos)
getReader
in class TransactionLog
public TransactionLog.LogReader getSortedReader(long startingPos)
getSortedReader
in class TransactionLog
public TransactionLog.ReverseReader getReverseReader() throws IOException
getReverseReader
in class TransactionLog
IOException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.