org.apache.hadoop.hbase.client

Class SecureBulkLoadClient

java.lang.Object

org.apache.hadoop.hbase.client.SecureBulkLoadClient

@InterfaceAudience.Private
public class SecureBulkLoadClient
extends Object

Client proxy for SecureBulkLoadProtocol

Constructor Summary

Constructors

Constructor and Description
SecureBulkLoadClient(org.apache.hadoop.conf.Configuration conf, Table table)

Method Summary

Modifier and Type	Method and Description
void	cleanupBulkLoad(Connection conn, String bulkToken)
String	prepareBulkLoad(Connection conn)
boolean	secureBulkLoadHFiles(ClientProtos.ClientService.BlockingInterface client, List<Pair<byte[],String>> familyPaths, byte[] regionName, boolean assignSeqNum, org.apache.hadoop.security.token.Token<?> userToken, String bulkToken) Securely bulk load a list of HFiles using client protocol.
boolean	secureBulkLoadHFiles(ClientProtos.ClientService.BlockingInterface client, List<Pair<byte[],String>> familyPaths, byte[] regionName, boolean assignSeqNum, org.apache.hadoop.security.token.Token<?> userToken, String bulkToken, boolean copyFiles) Securely bulk load a list of HFiles using client protocol.

Methods inherited from class java.lang.Object

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

Constructor Detail

SecureBulkLoadClient

public SecureBulkLoadClient(org.apache.hadoop.conf.Configuration conf,
                            Table table)

Method Detail

prepareBulkLoad

public String prepareBulkLoad(Connection conn)
                       throws IOException

Throws:

IOException

cleanupBulkLoad

public void cleanupBulkLoad(Connection conn,
                            String bulkToken)
                     throws IOException

Throws:

IOException

secureBulkLoadHFiles

public boolean secureBulkLoadHFiles(ClientProtos.ClientService.BlockingInterface client,
                                    List<Pair<byte[],String>> familyPaths,
                                    byte[] regionName,
                                    boolean assignSeqNum,
                                    org.apache.hadoop.security.token.Token<?> userToken,
                                    String bulkToken)
                             throws IOException

Securely bulk load a list of HFiles using client protocol.

Parameters:

client -

familyPaths -

regionName -

assignSeqNum -

userToken -

bulkToken -

Returns:

true if all are loaded

Throws:

IOException

secureBulkLoadHFiles

public boolean secureBulkLoadHFiles(ClientProtos.ClientService.BlockingInterface client,
                                    List<Pair<byte[],String>> familyPaths,
                                    byte[] regionName,
                                    boolean assignSeqNum,
                                    org.apache.hadoop.security.token.Token<?> userToken,
                                    String bulkToken,
                                    boolean copyFiles)
                             throws IOException

Securely bulk load a list of HFiles using client protocol.

Parameters:

client -

familyPaths -

regionName -

assignSeqNum -

userToken -

bulkToken -

copyFiles -

Returns:

true if all are loaded

Throws:

IOException