Field Detail

• fs

  private org.apache.hadoop.fs.FileSystem fs

• stagingDir

  private String stagingDir

• conf

  private 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

• SecureBulkLoadEndpoint.SecureBulkLoadListener

  public SecureBulkLoadEndpoint.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)
                         throws IOException

  Description copied from interface: Region.BulkLoadListener
  Called before an HFile is actually loaded

  Specified by:

  prepareBulkLoad in interface Region.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: Region.BulkLoadListener
  Called after a successful HFile load

  Specified by:

  doneBulkLoad in interface Region.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: Region.BulkLoadListener
  Called after a failed HFile load

  Specified by:

  failedBulkLoad in interface Region.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