Package 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	Description
(package private) long	editsSkipped
(package private) long	editsWritten
(package private) final byte[]	encodedRegionName
(package private) final long	minLogSeqNum
(package private) long	nanosSpent
(package private) final org.apache.hadoop.fs.Path	path
(package private) final WALProvider.Writer	writer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

RecoveredEditsWriter

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

Method Details

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)