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

private static class SecureBulkLoadManager.SecureBulkLoadListener
extends Object
implements HRegion.BulkLoadListener

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
private void	closeSrcFs()
void	doneBulkLoad(byte[] family, String srcPath) Called after a successful HFile load
void	failedBulkLoad(byte[] family, String srcPath) 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) 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 Detail

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

Constructor Detail

SecureBulkLoadListener

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

Method Detail

prepareBulkLoad

public String prepareBulkLoad(byte[] family,
                              String srcPath,
                              boolean copyFile)
                       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 srcPath)
                    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

srcPath - 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.

Parameters:

p -

Returns:

true if the p is a file

Throws:

IOException