Package org.apache.accumulo.core.client

Interface MultiTableBatchWriter

All Superinterfaces:

AutoCloseable

public interface MultiTableBatchWriter
extends AutoCloseable

This class enables efficient batch writing to multiple tables. When creating a batch writer for each table, each has its own memory and network resources. Using this class these resources may be shared among multiple tables.

Method Summary

Modifier and Type	Method	Description
void	close()	Flush and release all resources.
void	flush()	Send mutations for all tables to accumulo.
BatchWriter	getBatchWriter(String table)	Returns a BatchWriter for a particular table.
boolean	isClosed()	Returns true if this batch writer has been closed.

Method Details

getBatchWriter

BatchWriter getBatchWriter(String table)
                    throws AccumuloException,
AccumuloSecurityException,
TableNotFoundException

Returns a BatchWriter for a particular table.

Parameters:

table - the name of a table whose batch writer you wish to retrieve

Returns:

an instance of a batch writer for the specified table

Throws:

AccumuloException - when a general exception occurs with accumulo

AccumuloSecurityException - when the user is not allowed to insert data into that table

TableNotFoundException - when the table does not exist

flush

void flush()
    throws MutationsRejectedException

Send mutations for all tables to accumulo.

Throws:

MutationsRejectedException - when queued mutations are unable to be inserted

close

void close()
    throws MutationsRejectedException

Flush and release all resources.

Specified by:

close in interface AutoCloseable

Throws:

MutationsRejectedException - when queued mutations are unable to be inserted

isClosed

boolean isClosed()

Returns true if this batch writer has been closed.

Returns:

true if this batch writer has been closed