WALInputFormat (Apache HBase 1.2.12 API)

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

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

Simple InputFormat for WAL files.

Field Summary

Fields
Modifier and Type Field and Description

static String END_TIME_KEY

static String START_TIME_KEY

Fields
Modifier and Type	Field and Description
`static String`	`END_TIME_KEY`
`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<org.apache.hadoop.hbase.wal.WALKey,org.apache.hadoop.hbase.regionserver.wal.WALEdit>`	`createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)`
`List<org.apache.hadoop.mapreduce.InputSplit>`	`getSplits(org.apache.hadoop.mapreduce.JobContext context)`

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

Field Detail
- 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<org.apache.hadoop.hbase.wal.WALKey,org.apache.hadoop.hbase.regionserver.wal.WALEdit>
Throws:: IOException; InterruptedException

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.hbase.wal.WALKey,org.apache.hadoop.hbase.regionserver.wal.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<org.apache.hadoop.hbase.wal.WALKey,org.apache.hadoop.hbase.regionserver.wal.WALEdit>
Throws:: IOException; InterruptedException

Class WALInputFormat

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

START_TIME_KEY

END_TIME_KEY

Constructor Detail

WALInputFormat

Method Detail

getSplits

createRecordReader