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

Field Summary

Fields

Modifier and Type	Field and Description
private RpcControllerFactory	rpcControllerFactory
private Table	table

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(org.apache.hadoop.hbase.shaded.protobuf.generated.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(org.apache.hadoop.hbase.shaded.protobuf.generated.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

Field Detail

table

private Table table

rpcControllerFactory

private final RpcControllerFactory rpcControllerFactory

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(org.apache.hadoop.hbase.shaded.protobuf.generated.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(org.apache.hadoop.hbase.shaded.protobuf.generated.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