public class FaultyProtobufWALStreamReader extends org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader
Modifier and Type | Class and Description |
---|---|
static class |
FaultyProtobufWALStreamReader.FailureType |
Modifier and Type | Field and Description |
---|---|
(package private) Queue<org.apache.hadoop.hbase.wal.WAL.Entry> |
nextQueue |
(package private) int |
numberOfFileEntries |
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 and Description |
---|
FaultyProtobufWALStreamReader() |
Modifier and Type | Method and Description |
---|---|
(package private) FaultyProtobufWALStreamReader.FailureType |
getFailureType() |
org.apache.hadoop.hbase.wal.WAL.Entry |
next(org.apache.hadoop.hbase.wal.WAL.Entry reuse) |
getCellCodecInputStream, skipTo
close, extractHiddenEof, getCodecClsName, getPosition, getPositionQuietly, getWriterClsNames, init, initWALCellCodec, isWALTrailer, open, reachWALEditsStopOffset, readHeader, readTrailer, trailerSize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
int numberOfFileEntries
public FaultyProtobufWALStreamReader()
FaultyProtobufWALStreamReader.FailureType getFailureType()
public org.apache.hadoop.hbase.wal.WAL.Entry next(org.apache.hadoop.hbase.wal.WAL.Entry reuse) throws IOException
next
in interface org.apache.hadoop.hbase.wal.WALStreamReader
next
in class org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.