org.apache.accumulo.server.client
Class BulkImporter
java.lang.Object
org.apache.accumulo.server.client.BulkImporter
public class BulkImporter
- extends Object
Method Summary |
static List<String> |
bulkLoad(AccumuloConfiguration conf,
Instance instance,
AuthInfo 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)
|
static List<TabletLocator.TabletLocation> |
findOverlappingTablets(AccumuloConfiguration acuConf,
org.apache.hadoop.fs.FileSystem fs,
TabletLocator locator,
org.apache.hadoop.fs.Path file,
KeyExtent failed)
|
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)
|
BulkImporter.AssignmentStats |
importFiles(List<String> files,
org.apache.hadoop.fs.Path failureDir)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BulkImporter
public BulkImporter(AccumuloConfiguration conf,
Instance instance,
AuthInfo credentials,
long tid,
String tableId,
boolean setTime)
bulkLoad
public static List<String> bulkLoad(AccumuloConfiguration conf,
Instance instance,
AuthInfo creds,
long tid,
String tableId,
List<String> files,
String errorDir,
boolean setTime)
throws IOException,
AccumuloException,
AccumuloSecurityException,
ThriftTableOperationException
- Throws:
IOException
AccumuloException
AccumuloSecurityException
ThriftTableOperationException
importFiles
public BulkImporter.AssignmentStats importFiles(List<String> files,
org.apache.hadoop.fs.Path failureDir)
throws IOException,
AccumuloException,
AccumuloSecurityException,
ThriftTableOperationException
- Throws:
IOException
AccumuloException
AccumuloSecurityException
ThriftTableOperationException
findOverlappingTablets
public static List<TabletLocator.TabletLocation> findOverlappingTablets(AccumuloConfiguration acuConf,
org.apache.hadoop.fs.FileSystem fs,
TabletLocator locator,
org.apache.hadoop.fs.Path file)
throws Exception
- Throws:
Exception
findOverlappingTablets
public static List<TabletLocator.TabletLocation> findOverlappingTablets(AccumuloConfiguration acuConf,
org.apache.hadoop.fs.FileSystem fs,
TabletLocator locator,
org.apache.hadoop.fs.Path file,
KeyExtent failed)
throws Exception
- Throws:
Exception
findOverlappingTablets
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)
throws Exception
- Throws:
Exception
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.