org.apache.hadoop.hbase.regionserver.wal

Class FaultyProtobufLogReader

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.ReaderBase

org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

org.apache.hadoop.hbase.regionserver.wal.FaultyProtobufLogReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.wal.AbstractFSWALProvider.Reader, org.apache.hadoop.hbase.wal.WAL.Reader

public class FaultyProtobufLogReader
extends org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FaultyProtobufLogReader.FailureType

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrContext, org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrResult

Field Summary

Fields

Modifier and Type	Field and Description
(package private) Queue<org.apache.hadoop.hbase.wal.WAL.Entry>	nextQueue
(package private) int	numberOfFileEntries

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

byteStringUncompressor, cellDecoder, DEFAULT_WAL_TRAILER_WARN_SIZE, hasCompression, hasTagCompression, hasValueCompression, inputStream, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerWarnSize, valueCompressionType, WAL_TRAILER_WARN_SIZE

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.ReaderBase

compressionContext, conf, edit, emptyCompressionContext, fileLength, fs, path

Constructor Summary

Constructors

Constructor and Description
FaultyProtobufLogReader()

Method Summary

Modifier and Type	Method and Description
(package private) FaultyProtobufLogReader.FailureType	getFailureType()
org.apache.hadoop.hbase.wal.WAL.Entry	next(org.apache.hadoop.hbase.wal.WAL.Entry reuse)

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader

close, getCodec, getCodecClsName, getPosition, getValueCompressionAlgorithm, getWriterClsNames, hasCompression, hasTagCompression, hasValueCompression, init, initAfterCompression, initAfterCompression, initReader, readHeader, readNext, reset, seekOnFs, trailerSize

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.ReaderBase

next, seek

Methods inherited from class java.lang.Object

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

Field Detail

nextQueue

Queue<org.apache.hadoop.hbase.wal.WAL.Entry> nextQueue

numberOfFileEntries

int numberOfFileEntries

Constructor Detail

FaultyProtobufLogReader

public FaultyProtobufLogReader()

Method Detail

getFailureType

FaultyProtobufLogReader.FailureType getFailureType()

next

public org.apache.hadoop.hbase.wal.WAL.Entry next(org.apache.hadoop.hbase.wal.WAL.Entry reuse)
                                           throws IOException

Specified by:

next in interface org.apache.hadoop.hbase.wal.WAL.Reader

Overrides:

next in class org.apache.hadoop.hbase.regionserver.wal.ReaderBase

Throws:

IOException