org.apache.hadoop.hbase.client.coprocessor

Class SecureBulkLoadClient

java.lang.Object

org.apache.hadoop.hbase.client.coprocessor.SecureBulkLoadClient

@InterfaceAudience.Private
public class SecureBulkLoadClient
extends Object

Client proxy for SecureBulkLoadProtocol used in conjunction with SecureBulkLoadEndpoint

Constructor Summary

Constructors

Constructor and Description
SecureBulkLoadClient(HTable table)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	bulkLoadHFiles(List<Pair<byte[],String>> familyPaths, org.apache.hadoop.security.token.Token<?> userToken, String bulkToken, byte[] startRow)
void	cleanupBulkLoad(String bulkToken)
org.apache.hadoop.fs.Path	getStagingPath(String bulkToken, byte[] family)
String	prepareBulkLoad(TableName tableName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SecureBulkLoadClient

public SecureBulkLoadClient(HTable table)

Method Detail

prepareBulkLoad

public String prepareBulkLoad(TableName tableName)
                       throws IOException

Throws:

IOException

cleanupBulkLoad

public void cleanupBulkLoad(String bulkToken)
                     throws IOException

Throws:

IOException

bulkLoadHFiles

public boolean bulkLoadHFiles(List<Pair<byte[],String>> familyPaths,
                     org.apache.hadoop.security.token.Token<?> userToken,
                     String bulkToken,
                     byte[] startRow)
                       throws IOException

Throws:

IOException

getStagingPath

public org.apache.hadoop.fs.Path getStagingPath(String bulkToken,
                                       byte[] family)
                                         throws IOException

Throws:

IOException