public class TableSnapshotScanner
extends AbstractClientScanner
This also allows one to run the scan from an online or offline hbase cluster. The snapshot files can be exported by using the org.apache.hadoop.hbase.snapshot.ExportSnapshot tool, to a pure-hdfs cluster, and this scanner can be used to run the scan directly over the snapshot files. The snapshot should not be deleted while there are open scanners reading from snapshot files.
An internal RegionScanner is used to execute the Scan
obtained
from the user for each region in the snapshot.
HBase owns all the data and snapshot files on the filesystem. Only the HBase user can read from snapshot files and data files. HBase also enforces security because all the requests are handled by the server layer, and the user cannot read from the data files directly. To read from snapshot files directly from the file system, the user who is running the MR job must have sufficient permissions to access snapshot and reference files. This means that to run mapreduce over snapshot files, the job has to be run as the HBase user or the user must have group or other priviledges in the filesystem (See HBASE-8369). Note that, given other users access to read from snapshot/data files will completely circumvent the access control enforced by HBase. See org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormat.
Constructor and Description |
---|
TableSnapshotScanner(Configuration conf,
Path rootDir,
Path restoreDir,
java.lang.String snapshotName,
Scan scan) |
TableSnapshotScanner(Configuration conf,
Path rootDir,
Path restoreDir,
java.lang.String snapshotName,
Scan scan,
boolean snapshotAlreadyRestored)
Creates a TableSnapshotScanner.
|
TableSnapshotScanner(Configuration conf,
Path restoreDir,
java.lang.String snapshotName,
Scan scan)
Creates a TableSnapshotScanner.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
Result |
next() |
boolean |
renewLease() |
public TableSnapshotScanner(Configuration conf, Path restoreDir, java.lang.String snapshotName, Scan scan) throws java.io.IOException
conf
- the configurationrestoreDir
- a temporary directory to copy the snapshot files into. Current user should
have write permissions to this directory, and this should not be a subdirectory of
rootDir. The scanner deletes the contents of the directory once the scanner is closed.snapshotName
- the name of the snapshot to read fromscan
- a Scan representing scan parametersjava.io.IOException
- in case of errorpublic TableSnapshotScanner(Configuration conf, Path rootDir, Path restoreDir, java.lang.String snapshotName, Scan scan) throws java.io.IOException
java.io.IOException
public TableSnapshotScanner(Configuration conf, Path rootDir, Path restoreDir, java.lang.String snapshotName, Scan scan, boolean snapshotAlreadyRestored) throws java.io.IOException
conf
- the configurationrootDir
- root directory for HBase.restoreDir
- a temporary directory to copy the snapshot files into. Current user should
have write permissions to this directory, and this should not be a subdirectory of
rootdir. The scanner deletes the contents of the directory once the scanner is closed.snapshotName
- the name of the snapshot to read fromscan
- a Scan representing scan parameterssnapshotAlreadyRestored
- true to indicate that snapshot has been restored.java.io.IOException
- in case of error