public class MultiTableSnapshotInputFormatImpl
extends java.lang.Object
.MultiTableSnapshotInputFormat
and mapred
(MultiTableSnapshotInputFormat
implementations.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
RESTORE_DIRS_KEY |
static java.lang.String |
SNAPSHOT_TO_SCANS_KEY |
Constructor and Description |
---|
MultiTableSnapshotInputFormatImpl() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,Path> |
getSnapshotDirs(Configuration conf)
Retrieve the directories into which snapshots have been restored from
(
RESTORE_DIRS_KEY ) |
java.util.Map<java.lang.String,java.util.Collection<Scan>> |
getSnapshotsToScans(Configuration conf)
Retrieve the snapshot name -> list<scan> mapping pushed to configuration by
#setSnapshotToScans(org.apache.hadoop.conf.Configuration, java.util.Map) |
java.util.List<TableSnapshotInputFormatImpl.InputSplit> |
getSplits(Configuration conf)
Return the list of splits extracted from the scans/snapshots pushed to conf by
#setInput(org.apache.hadoop.conf.Configuration, java.util.Map, org.apache.hadoop.fs.Path) |
void |
restoreSnapshots(Configuration conf,
java.util.Map<java.lang.String,Path> snapshotToDir,
FileSystem fs)
Restore each (snapshot name, restore directory) pair in snapshotToDir
|
void |
setInput(Configuration conf,
java.util.Map<java.lang.String,java.util.Collection<Scan>> snapshotScans,
Path restoreDir)
Configure conf to read from snapshotScans, with snapshots restored to a subdirectory of
restoreDir.
|
void |
setSnapshotDirs(Configuration conf,
java.util.Map<java.lang.String,Path> snapshotDirs) |
void |
setSnapshotToScans(Configuration conf,
java.util.Map<java.lang.String,java.util.Collection<Scan>> snapshotScans)
Push snapshotScans to conf (under the key
SNAPSHOT_TO_SCANS_KEY ) |
public static final java.lang.String RESTORE_DIRS_KEY
public static final java.lang.String SNAPSHOT_TO_SCANS_KEY
public void setInput(Configuration conf, java.util.Map<java.lang.String,java.util.Collection<Scan>> snapshotScans, Path restoreDir) throws java.io.IOException
RESTORE_DIRS_KEY
, SNAPSHOT_TO_SCANS_KEY
conf
- snapshotScans
- restoreDir
- java.io.IOException
public java.util.List<TableSnapshotInputFormatImpl.InputSplit> getSplits(Configuration conf) throws java.io.IOException
#setInput(org.apache.hadoop.conf.Configuration, java.util.Map, org.apache.hadoop.fs.Path)
conf
- Configuration to determine splits fromjava.io.IOException
public java.util.Map<java.lang.String,java.util.Collection<Scan>> getSnapshotsToScans(Configuration conf) throws java.io.IOException
#setSnapshotToScans(org.apache.hadoop.conf.Configuration, java.util.Map)
conf
- Configuration to extract name -> list<scan> mappings from.java.io.IOException
public void setSnapshotToScans(Configuration conf, java.util.Map<java.lang.String,java.util.Collection<Scan>> snapshotScans) throws java.io.IOException
SNAPSHOT_TO_SCANS_KEY
)conf
- snapshotScans
- java.io.IOException
public java.util.Map<java.lang.String,Path> getSnapshotDirs(Configuration conf) throws java.io.IOException
RESTORE_DIRS_KEY
)conf
- Configuration to extract restore directories fromjava.io.IOException
public void setSnapshotDirs(Configuration conf, java.util.Map<java.lang.String,Path> snapshotDirs)
public void restoreSnapshots(Configuration conf, java.util.Map<java.lang.String,Path> snapshotToDir, FileSystem fs) throws java.io.IOException
conf
- configuration to restore withsnapshotToDir
- mapping from snapshot names to restore directoriesfs
- filesystem to do snapshot restoration onjava.io.IOException