Package org.apache.accumulo.core.client.admin

Interface TableOperations.ImportMappingOptions

All Superinterfaces:

TableOperations.ImportOptions

Enclosing interface:

TableOperations

public static interface TableOperations.ImportMappingOptions
extends TableOperations.ImportOptions

Options giving control of how the bulk import file mapping is done.

Since:

2.0.0

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BULK_LOAD_THREADS_DEFAULT	This is the default number of threads used to determine where to load files.

Method Summary

Modifier and Type	Method	Description
TableOperations.ImportOptions	executor(Executor service)	Files are examined to determine where to load them.
TableOperations.ImportOptions	plan(LoadPlan service)	Load files in the directory to the row ranges specified in the plan.
TableOperations.ImportOptions	threads(int numThreads)	Files are examined to determine where to load them.

Methods inherited from interface org.apache.accumulo.core.client.admin.TableOperations.ImportOptions

ignoreEmptyDir, load, tableTime

Field Details

BULK_LOAD_THREADS_DEFAULT

static final String BULK_LOAD_THREADS_DEFAULT

This is the default number of threads used to determine where to load files. A suffix of C means to multiply by the number of cores.

See Also:

• Constant Field Values

Method Details

plan

TableOperations.ImportOptions plan(LoadPlan service)

Load files in the directory to the row ranges specified in the plan. The plan should contain at least one entry for every file in the directory. When this option is specified, the files are never examined so it is possible to send files to the wrong tablet.

executor

TableOperations.ImportOptions executor(Executor service)

Files are examined to determine where to load them. This examination is done in the current process using multiple threads. If this method is not called, then the client property bulk.threads is used to create a thread pool. This property defaults to "8C".

Parameters:

service - Use this executor to run file examination task

threads

TableOperations.ImportOptions threads(int numThreads)

Files are examined to determine where to load them. This examination is done in the current process using multiple threads. If this method is not called, then the client property bulk.threads is used to create a thread pool. This property defaults to "8C".

Parameters:

numThreads - Create a thread pool with this many thread to run file examination task.