org.apache.accumulo.server.client
public class BulkImporter extends Object
Modifier and Type | Class and Description |
---|---|
static class |
BulkImporter.AssignmentStats |
Constructor and Description |
---|
BulkImporter(AccumuloConfiguration conf,
Instance instance,
TCredentials credentials,
long tid,
String tableId,
boolean setTime) |
Modifier and Type | Method and Description |
---|---|
static List<String> |
bulkLoad(AccumuloConfiguration conf,
Instance instance,
TCredentials creds,
long tid,
String tableId,
List<String> files,
String errorDir,
boolean setTime) |
static List<TabletLocator.TabletLocation> |
findOverlappingTablets(AccumuloConfiguration acuConf,
org.apache.hadoop.fs.FileSystem fs,
TabletLocator locator,
org.apache.hadoop.fs.Path file,
KeyExtent failed,
TCredentials credentials) |
static List<TabletLocator.TabletLocation> |
findOverlappingTablets(AccumuloConfiguration acuConf,
org.apache.hadoop.fs.FileSystem fs,
TabletLocator locator,
org.apache.hadoop.fs.Path file,
TCredentials credentials) |
static List<TabletLocator.TabletLocation> |
findOverlappingTablets(AccumuloConfiguration acuConf,
org.apache.hadoop.fs.FileSystem fs,
TabletLocator locator,
org.apache.hadoop.fs.Path file,
org.apache.hadoop.io.Text startRow,
org.apache.hadoop.io.Text endRow,
TCredentials credentials) |
protected static org.apache.hadoop.io.Text |
getStartRowForExtent(KeyExtent extent) |
BulkImporter.AssignmentStats |
importFiles(List<String> files,
org.apache.hadoop.fs.Path failureDir) |
public BulkImporter(AccumuloConfiguration conf, Instance instance, TCredentials credentials, long tid, String tableId, boolean setTime)
public static List<String> bulkLoad(AccumuloConfiguration conf, Instance instance, TCredentials creds, long tid, String tableId, List<String> files, String errorDir, boolean setTime) throws IOException, AccumuloException, AccumuloSecurityException, ThriftTableOperationException
public BulkImporter.AssignmentStats importFiles(List<String> files, org.apache.hadoop.fs.Path failureDir) throws IOException, AccumuloException, AccumuloSecurityException, ThriftTableOperationException
public static List<TabletLocator.TabletLocation> findOverlappingTablets(AccumuloConfiguration acuConf, org.apache.hadoop.fs.FileSystem fs, TabletLocator locator, org.apache.hadoop.fs.Path file, TCredentials credentials) throws Exception
Exception
public static List<TabletLocator.TabletLocation> findOverlappingTablets(AccumuloConfiguration acuConf, org.apache.hadoop.fs.FileSystem fs, TabletLocator locator, org.apache.hadoop.fs.Path file, KeyExtent failed, TCredentials credentials) throws Exception
Exception
protected static org.apache.hadoop.io.Text getStartRowForExtent(KeyExtent extent)
public static List<TabletLocator.TabletLocation> findOverlappingTablets(AccumuloConfiguration acuConf, org.apache.hadoop.fs.FileSystem fs, TabletLocator locator, org.apache.hadoop.fs.Path file, org.apache.hadoop.io.Text startRow, org.apache.hadoop.io.Text endRow, TCredentials credentials) throws Exception
Exception
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.