org.apache.hadoop.hbase.mapred

Class TableSnapshotInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapred.TableSnapshotInputFormat

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class TableSnapshotInputFormat
extends Object

TableSnapshotInputFormat allows a MapReduce job to run over a table snapshot. Further documentation available on TableSnapshotInputFormat.

See Also:

TableSnapshotInputFormat

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TableSnapshotInputFormat.TableSnapshotRegionSplit

Constructor Summary

Constructors

Constructor and Description
TableSnapshotInputFormat()

Method Summary

Modifier and Type	Method and Description
<any>	getRecordReader(InputSplit split, JobConf job, Reporter reporter)
InputSplit[]	getSplits(JobConf job, int numSplits)
static void	setInput(JobConf job, String snapshotName, Path restoreDir) Configures the job to use TableSnapshotInputFormat to read from a snapshot.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TableSnapshotInputFormat

public TableSnapshotInputFormat()

Method Detail

getSplits

public InputSplit[] getSplits(JobConf job,
                              int numSplits)
                       throws IOException

Throws:

IOException

getRecordReader

public <any> getRecordReader(InputSplit split,
                             JobConf job,
                             Reporter reporter)
                      throws IOException

Throws:

IOException

setInput

public static void setInput(JobConf job,
                            String snapshotName,
                            Path restoreDir)
                     throws IOException

Configures the job to use TableSnapshotInputFormat to read from a snapshot.

Parameters:

job - the job to configure

snapshotName - the name of the snapshot to read from

restoreDir - a temporary directory to restore the snapshot into. Current user should have write permissions to this directory, and this should not be a subdirectory of rootdir. After the job is finished, restoreDir can be deleted.

Throws:

IOException - if an error occurs