Package org.apache.hadoop.hbase.regionserver.wal

Class FaultyProtobufWALStreamReader

java.lang.Object
org.apache.hadoop.hbase.regionserver.wal.AbstractProtobufWALReader
org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader
org.apache.hadoop.hbase.regionserver.wal.FaultyProtobufWALStreamReader
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.hadoop.hbase.wal.AbstractFSWALProvider.Initializer, org.apache.hadoop.hbase.wal.WALStreamReader
public class FaultyProtobufWALStreamReader extends org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static enum 
    FaultyProtobufWALStreamReader.FailureType
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    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.AbstractProtobufWALReader

    byteStringUncompressor, cellDecoder, codecClsName, compressionCtx, conf, decryptor, DEFAULT_WAL_TRAILER_WARN_SIZE, fileLength, fs, hasCompression, hasTagCompression, hasValueCompression, inputStream, path, PB_WAL_COMPLETE_MAGIC, PB_WAL_MAGIC, trailer, trailerPresent, trailerWarnSize, valueCompressionType, WAL_TRAILER_WARN_SIZE, walEditsStopOffset

  • Constructor Summary

    Constructors
    Constructor
    Description
    FaultyProtobufWALStreamReader()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) FaultyProtobufWALStreamReader.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.ProtobufWALStreamReader

    getCellCodecInputStream, skipTo

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

    close, extractHiddenEof, getCodecClsName, getPosition, getPositionQuietly, getWriterClsNames, init, initWALCellCodec, isWALTrailer, open, reachWALEditsStopOffset, readHeader, readTrailer, trailerSize

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hbase.wal.AbstractFSWALProvider.Initializer

    init

    Methods inherited from interface org.apache.hadoop.hbase.wal.WALStreamReader

    close, getPosition, next