Package | Description |
---|---|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Field and Description |
---|---|
private WALStreamReader |
WALInputFormat.WALRecordReader.reader |
Modifier and Type | Method and Description |
---|---|
private WALStreamReader |
WALInputFormat.WALRecordReader.openReader(org.apache.hadoop.fs.Path path,
long startPosition) |
Modifier and Type | Class and Description |
---|---|
class |
ProtobufWALStreamReader
A one way stream reader for reading protobuf based WAL file.
|
Modifier and Type | Method and Description |
---|---|
private WALStreamReader |
ReplaySyncReplicationWALCallable.getReader(String wal) |
Modifier and Type | Method and Description |
---|---|
private List<WAL.Entry> |
ReplaySyncReplicationWALCallable.readWALEntries(WALStreamReader reader,
String wal) |
Modifier and Type | Field and Description |
---|---|
private Class<? extends WALStreamReader> |
WALFactory.walStreamReaderClass
Configuration-specified WAL Reader used when a custom reader is requested
|
Modifier and Type | Method and Description |
---|---|
WALStreamReader |
WALFactory.createStreamReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
WALStreamReader |
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.
|
WALStreamReader |
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 given
startPosition . |
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.
|
protected WALStreamReader |
WALSplitter.getReader(org.apache.hadoop.fs.FileStatus walStatus,
boolean skipErrors,
CancelableProgressable cancel)
Create a new
WALStreamReader for reading logs to split. |
private WALStreamReader |
WALSplitter.getReader(org.apache.hadoop.fs.Path curLogFile,
CancelableProgressable reporter)
Create a new
WALStreamReader for reading logs to split. |
Modifier and Type | Method and Description |
---|---|
private WAL.Entry |
WALSplitter.getNextLogLine(WALStreamReader in,
org.apache.hadoop.fs.Path path,
boolean skipErrors) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.