@InterfaceAudience.Private public class SecureBulkLoadClient extends Object
| Constructor and Description |
|---|
SecureBulkLoadClient(Table table) |
| 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) |
private Table table
public SecureBulkLoadClient(Table table)
public String prepareBulkLoad(TableName tableName) throws IOException
IOExceptionpublic void cleanupBulkLoad(String bulkToken) throws IOException
IOExceptionpublic boolean bulkLoadHFiles(List<Pair<byte[],String>> familyPaths, org.apache.hadoop.security.token.Token<?> userToken, String bulkToken, byte[] startRow) throws IOException
IOExceptionpublic org.apache.hadoop.fs.Path getStagingPath(String bulkToken, byte[] family) throws IOException
IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.