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 WAL.Reader |
WALInputFormat.WALRecordReader.reader |
Modifier and Type | Class and Description |
---|---|
class |
ProtobufLogReader
A Protobuf based WAL has the following structure:
|
class |
ReaderBase |
class |
SecureProtobufLogReader |
Modifier and Type | Field and Description |
---|---|
private WAL.Reader |
WALEntryStream.reader |
Modifier and Type | Interface and Description |
---|---|
static interface |
AbstractFSWALProvider.Reader |
Modifier and Type | Method and Description |
---|---|
WAL.Reader |
WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path) |
WAL.Reader |
WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
CancelableProgressable reporter)
Create a reader for the WAL.
|
WAL.Reader |
WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
CancelableProgressable reporter,
boolean allowCustom) |
static WAL.Reader |
WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration configuration)
Create a reader for the given path, accept custom reader classes from conf.
|
(package private) static WAL.Reader |
WALFactory.createReader(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration configuration,
CancelableProgressable reporter)
Create a reader for the given path, accept custom reader classes from conf.
|
static WAL.Reader |
WALFactory.createReaderIgnoreCustomClass(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration configuration)
Create a reader for the given path, ignore custom reader classes from conf.
|
protected WAL.Reader |
WALSplitter.getReader(org.apache.hadoop.fs.FileStatus walStatus,
boolean skipErrors,
CancelableProgressable cancel)
Create a new
WAL.Reader for reading logs to split. |
private WAL.Reader |
WALSplitter.getReader(org.apache.hadoop.fs.Path curLogFile,
CancelableProgressable reporter)
Create a new
WAL.Reader for reading logs to split. |
static WAL.Reader |
AbstractFSWALProvider.openReader(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf)
Opens WAL reader with retries and additional exception handling
|
Modifier and Type | Method and Description |
---|---|
private WAL.Entry |
WALSplitter.getNextLogLine(WAL.Reader in,
org.apache.hadoop.fs.Path path,
boolean skipErrors) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.