org.apache.hadoop.hbase.wal

Class AbstractRecoveredEditsOutputSink.RecoveredEditsWriter

java.lang.Object

org.apache.hadoop.hbase.wal.AbstractRecoveredEditsOutputSink.RecoveredEditsWriter

Enclosing class:

AbstractRecoveredEditsOutputSink

final class AbstractRecoveredEditsOutputSink.RecoveredEditsWriter
extends Object

Private data structure that wraps a WALProvider.Writer and its Path, also collecting statistics about the data written to this output.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	editsSkipped
(package private) long	editsWritten
(package private) byte[]	encodedRegionName
(package private) long	minLogSeqNum
(package private) long	nanosSpent
(package private) org.apache.hadoop.fs.Path	path
(package private) WALProvider.Writer	writer

Constructor Summary

Constructors

Constructor and Description
RecoveredEditsWriter(byte[] encodedRegionName, org.apache.hadoop.fs.Path path, WALProvider.Writer writer, long minLogSeqNum)

Method Summary

Modifier and Type	Method and Description
private void	filterCellByStore(WAL.Entry logEntry)
private void	incrementEdits(int edits)
private void	incrementNanoTime(long nanos)
private void	incrementSkippedEdits(int skipped)
private void	logAndThrowWriterAppendFailure(WAL.Entry logEntry, IOException e)
(package private) void	writeRegionEntries(List<WAL.Entry> entries)

Methods inherited from class java.lang.Object

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

Field Detail

editsWritten

long editsWritten

editsSkipped

long editsSkipped

nanosSpent

long nanosSpent

encodedRegionName

final byte[] encodedRegionName

path

final org.apache.hadoop.fs.Path path

writer

final WALProvider.Writer writer

minLogSeqNum

final long minLogSeqNum

Constructor Detail

RecoveredEditsWriter

RecoveredEditsWriter(byte[] encodedRegionName,
                     org.apache.hadoop.fs.Path path,
                     WALProvider.Writer writer,
                     long minLogSeqNum)

Method Detail

incrementEdits

private void incrementEdits(int edits)

incrementSkippedEdits

private void incrementSkippedEdits(int skipped)

incrementNanoTime

private void incrementNanoTime(long nanos)

writeRegionEntries

void writeRegionEntries(List<WAL.Entry> entries)
                 throws IOException

Throws:

IOException

logAndThrowWriterAppendFailure

private void logAndThrowWriterAppendFailure(WAL.Entry logEntry,
                                            IOException e)
                                     throws IOException

Throws:

IOException

filterCellByStore

private void filterCellByStore(WAL.Entry logEntry)