Package org.apache.hadoop.hbase.client

Class SecureBulkLoadClient

java.lang.Object

org.apache.hadoop.hbase.client.SecureBulkLoadClient

@Private
public class SecureBulkLoadClient
extends Object

Client proxy for SecureBulkLoadProtocol

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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.
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, List<String> clusterIds, boolean replicate)

Methods inherited from class java.lang.Object

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

Field Details

table

private Table table

rpcControllerFactory

private final RpcControllerFactory rpcControllerFactory

Constructor Details

SecureBulkLoadClient

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

Method Details

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.

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.

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,
 List<String> clusterIds,
 boolean replicate)
                             throws IOException

Throws:

IOException