@InterfaceAudience.Public @InterfaceStability.Evolving public class TableSnapshotInputFormat extends java.lang.Object
TableSnapshotInputFormat
.TableSnapshotInputFormat
Modifier and Type | Class and Description |
---|---|
static class |
TableSnapshotInputFormat.TableSnapshotRegionSplit |
Constructor and Description |
---|
TableSnapshotInputFormat() |
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,
java.lang.String snapshotName,
Path restoreDir)
Configures the job to use TableSnapshotInputFormat to read from a snapshot.
|
public InputSplit[] getSplits(JobConf job, int numSplits) throws java.io.IOException
java.io.IOException
public <any> getRecordReader(InputSplit split, JobConf job, Reporter reporter) throws java.io.IOException
java.io.IOException
public static void setInput(JobConf job, java.lang.String snapshotName, Path restoreDir) throws java.io.IOException
job
- the job to configuresnapshotName
- the name of the snapshot to read fromrestoreDir
- 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.java.io.IOException
- if an error occurs