org.apache.accumulo.server.client
Class BulkImporter

java.lang.Object
  extended by org.apache.accumulo.server.client.BulkImporter

public class BulkImporter
extends Object


Nested Class Summary
static class BulkImporter.AssignmentStats
           
 
Constructor Summary
BulkImporter(AccumuloConfiguration conf, Instance instance, AuthInfo credentials, long tid, String tableId, boolean setTime)
           
 
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
 

Constructor Detail

BulkImporter

public BulkImporter(AccumuloConfiguration conf,
                    Instance instance,
                    AuthInfo credentials,
                    long tid,
                    String tableId,
                    boolean setTime)
Method Detail

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.