SequenceFileLogReader.WALReader (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.io.SequenceFile.Reader
- - org.apache.hadoop.hbase.regionserver.wal.SequenceFileLogReader.WALReader

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

SequenceFileLogReader
```
private static class SequenceFileLogReader.WALReader
extends org.apache.hadoop.io.SequenceFile.Reader
```
Hack just to set the correct file length up in SequenceFile.Reader. See HADOOP-6307. The below is all about setting the right length on the file we are reading. fs.getFileStatus(file).getLen() is passed down to a private SequenceFile.Reader constructor. This won't work. Need to do the available on the stream. The below is ugly. It makes getPos, the first time its called, return length of the file -- i.e. tell a lie -- just so this line up in SF.Reader's constructor ends up with right answer: this.end = in.getPos() + length;

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`(package private) static class`	`SequenceFileLogReader.WALReader.WALReaderFSDataInputStream` Override just so can intercept first call to getPos.

Nested classes/interfaces inherited from class org.apache.hadoop.io.SequenceFile.Reader
org.apache.hadoop.io.SequenceFile.Reader.Option

Constructor Summary

Constructors
Constructor and Description
`SequenceFileLogReader.WALReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, org.apache.hadoop.conf.Configuration c)`

Method Summary

Methods
Modifier and Type	Method and Description
`protected org.apache.hadoop.fs.FSDataInputStream`	`openFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, int bufferSize, long length)`

Methods inherited from class org.apache.hadoop.io.SequenceFile.Reader
bufferSize, close, createValueBytes, file, getCompressionCodec, getCompressionType, getCurrentValue, getCurrentValue, getKeyClass, getKeyClassName, getMetadata, getPosition, getValueClass, getValueClassName, isBlockCompressed, isCompressed, length, next, next, next, nextRaw, nextRawKey, nextRawValue, seek, start, stream, sync, syncSeen, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SequenceFileLogReader.WALReader

SequenceFileLogReader.WALReader(org.apache.hadoop.fs.FileSystem fs,
                               org.apache.hadoop.fs.Path p,
                               org.apache.hadoop.conf.Configuration c)
                          throws IOException

Throws:: IOException

Method Detail

openFile

protected org.apache.hadoop.fs.FSDataInputStream openFile(org.apache.hadoop.fs.FileSystem fs,
                                              org.apache.hadoop.fs.Path file,
                                              int bufferSize,
                                              long length)
                                                   throws IOException

Overrides:: openFile in class org.apache.hadoop.io.SequenceFile.Reader
Throws:: IOException

Class SequenceFileLogReader.WALReader

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.io.SequenceFile.Reader

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.io.SequenceFile.Reader

Methods inherited from class java.lang.Object

Constructor Detail

SequenceFileLogReader.WALReader

Method Detail

openFile