Package org.apache.hadoop.hbase.regionserver

Class SecureBulkLoadManager.SecureBulkLoadListener

java.lang.Object

org.apache.hadoop.hbase.regionserver.SecureBulkLoadManager.SecureBulkLoadListener

All Implemented Interfaces:

HRegion.BulkLoadListener

Enclosing class:

SecureBulkLoadManager

static class SecureBulkLoadManager.SecureBulkLoadListener
extends Object
implements HRegion.BulkLoadListener

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.conf.Configuration	conf
private final org.apache.hadoop.fs.FileSystem	fs
private Map<String,org.apache.hadoop.fs.permission.FsPermission>	origPermissions
private Map<String,String>	origSources
private org.apache.hadoop.fs.FileSystem	srcFs
private final String	stagingDir

Constructor Summary

Constructors

Constructor	Description
SecureBulkLoadListener(org.apache.hadoop.fs.FileSystem fs, String stagingDir, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private void	closeSrcFs()
void	doneBulkLoad(byte[] family, String srcPath)	Called after a successful HFile load
void	failedBulkLoad(byte[] family, String stagedPath)	Called after a failed HFile load
private boolean	isFile(org.apache.hadoop.fs.Path p)	Check if the path is referencing a file.
String	prepareBulkLoad(byte[] family, String srcPath, boolean copyFile, String customStaging)	Called before an HFile is actually loaded

Methods inherited from class java.lang.Object

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

Field Details

fs

private final org.apache.hadoop.fs.FileSystem fs

stagingDir

private final String stagingDir

conf

private final org.apache.hadoop.conf.Configuration conf

srcFs

private org.apache.hadoop.fs.FileSystem srcFs

origPermissions

private Map<String,org.apache.hadoop.fs.permission.FsPermission> origPermissions

origSources

private Map<String,String> origSources

Constructor Details

SecureBulkLoadListener

public SecureBulkLoadListener(org.apache.hadoop.fs.FileSystem fs,
 String stagingDir,
 org.apache.hadoop.conf.Configuration conf)

Method Details

prepareBulkLoad

public String prepareBulkLoad(byte[] family,
 String srcPath,
 boolean copyFile,
 String customStaging)
                       throws IOException

Description copied from interface: HRegion.BulkLoadListener

Called before an HFile is actually loaded

Specified by:

prepareBulkLoad in interface HRegion.BulkLoadListener

Parameters:

family - family being loaded to

srcPath - path of HFile

Returns:

final path to be used for actual loading

Throws:

IOException

doneBulkLoad

public void doneBulkLoad(byte[] family,
 String srcPath)
                  throws IOException

Description copied from interface: HRegion.BulkLoadListener

Called after a successful HFile load

Specified by:

doneBulkLoad in interface HRegion.BulkLoadListener

Parameters:

family - family being loaded to

srcPath - path of HFile

Throws:

IOException

closeSrcFs

private void closeSrcFs()
                 throws IOException

Throws:

IOException

failedBulkLoad

public void failedBulkLoad(byte[] family,
 String stagedPath)
                    throws IOException

Description copied from interface: HRegion.BulkLoadListener

Called after a failed HFile load

Specified by:

failedBulkLoad in interface HRegion.BulkLoadListener

Parameters:

family - family being loaded to

stagedPath - path of HFile

Throws:

IOException

isFile

private boolean isFile(org.apache.hadoop.fs.Path p)
                throws IOException

Check if the path is referencing a file. This is mainly needed to avoid symlinks.

Returns:

true if the p is a file

Throws:

IOException