Uses of Interface
org.apache.hadoop.hbase.wal.WALStreamReader
Package
Description
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
-
Uses of WALStreamReader in org.apache.hadoop.hbase.mapreduce
Modifier and TypeMethodDescriptionprivate WALStreamReader
WALInputFormat.WALRecordReader.openReader
(org.apache.hadoop.fs.Path path, long startPosition) -
Uses of WALStreamReader in org.apache.hadoop.hbase.regionserver.wal
Modifier and TypeClassDescriptionclass
A one way stream reader for reading protobuf based WAL file. -
Uses of WALStreamReader in org.apache.hadoop.hbase.wal
Modifier and TypeFieldDescriptionprivate final Class<? extends WALStreamReader>
WALFactory.walStreamReaderClass
Configuration-specified WAL Reader used when a custom reader is requestedModifier and TypeMethodDescriptionWALFactory.createStreamReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) static WALStreamReader
WALFactory.createStreamReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf) Create a one-way stream reader for a given path.static WALStreamReader
WALFactory.createStreamReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf, long startPosition) Create a one-way stream reader for a given path.WALFactory.createStreamReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, CancelableProgressable reporter) Create a one-way stream reader for the WAL.WALFactory.createStreamReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, CancelableProgressable reporter, long startPosition) Create a one-way stream reader for the WAL, and start reading from the givenstartPosition
.protected WALStreamReader
WALSplitter.getReader
(org.apache.hadoop.fs.FileStatus walStatus, boolean skipErrors, CancelableProgressable cancel) Create a newWALStreamReader
for reading logs to split.private WALStreamReader
WALSplitter.getReader
(org.apache.hadoop.fs.Path curLogFile, CancelableProgressable reporter) Create a newWALStreamReader
for reading logs to split.Modifier and TypeMethodDescriptionprivate WAL.Entry
WALSplitter.getNextLogLine
(WALStreamReader in, org.apache.hadoop.fs.Path path, boolean skipErrors)