WALInputFormat (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.mapreduce.InputFormat<WALKey,WALEdit>
- - org.apache.hadoop.hbase.mapreduce.WALInputFormat

@InterfaceAudience.Public
public class WALInputFormat
extends org.apache.hadoop.mapreduce.InputFormat<WALKey,WALEdit>

Simple InputFormat for WAL files.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`(package private) static class`	`WALInputFormat.WALKeyRecordReader` handler for non-deprecated WALKey version.
`(package private) static class`	`WALInputFormat.WALRecordReader<K extends WALKey>` `RecordReader` for an `WAL` file.
`(package private) static class`	`WALInputFormat.WALSplit` `InputSplit` for `WAL` files.

Field Summary

Fields
Modifier and Type Field and Description

static String END_TIME_KEY

private static org.apache.commons.logging.Log LOG

static String START_TIME_KEY

Fields
Modifier and Type	Field and Description
`static String`	`END_TIME_KEY`
`private static org.apache.commons.logging.Log`	`LOG`
`static String`	`START_TIME_KEY`

Constructor Summary

Constructors
Constructor and Description

WALInputFormat()

Constructors
Constructor and Description
`WALInputFormat()`

Method Summary

Methods
Modifier and Type	Method and Description
`org.apache.hadoop.mapreduce.RecordReader<WALKey,WALEdit>`	`createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)`
`private List<org.apache.hadoop.fs.FileStatus>`	`getFiles(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path dir, long startTime, long endTime)`
`List<org.apache.hadoop.mapreduce.InputSplit>`	`getSplits(org.apache.hadoop.mapreduce.JobContext context)`
`(package private) List<org.apache.hadoop.mapreduce.InputSplit>`	`getSplits(org.apache.hadoop.mapreduce.JobContext context, String startKey, String endKey)` implementation shared with deprecated HLogInputFormat

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

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

START_TIME_KEY

public static final String START_TIME_KEY

See Also:: Constant Field Values

END_TIME_KEY

public static final String END_TIME_KEY

See Also:: Constant Field Values

Constructor Detail
- WALInputFormat
```
public WALInputFormat()
```

Method Detail

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                       throws IOException,
                                                              InterruptedException

Specified by:: getSplits in class org.apache.hadoop.mapreduce.InputFormat<WALKey,WALEdit>
Throws:: IOException; InterruptedException

getSplits

List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context,
                                                     String startKey,
                                                     String endKey)
                                                 throws IOException,
                                                        InterruptedException

implementation shared with deprecated HLogInputFormat

Throws:: IOException; InterruptedException

getFiles

private List<org.apache.hadoop.fs.FileStatus> getFiles(org.apache.hadoop.fs.FileSystem fs,
                                             org.apache.hadoop.fs.Path dir,
                                             long startTime,
                                             long endTime)
                                                throws IOException

Throws:: IOException

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<WALKey,WALEdit> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                          org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                            throws IOException,
                                                                                   InterruptedException

Specified by:: createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<WALKey,WALEdit>
Throws:: IOException; InterruptedException

Class WALInputFormat

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

START_TIME_KEY

END_TIME_KEY

Constructor Detail

WALInputFormat

Method Detail

getSplits

getSplits

getFiles

createRecordReader