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, TCredentials credentials, long tid, String tableId, boolean setTime)
           
 
Method Summary
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)
           
 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,
                    TCredentials credentials,
                    long tid,
                    String tableId,
                    boolean setTime)
Method Detail

bulkLoad

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
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,
                                                                        TCredentials credentials)
                                                                 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,
                                                                        TCredentials credentials)
                                                                 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,
                                                                        TCredentials credentials)
                                                                 throws Exception
Throws:
Exception


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.