org.apache.accumulo.core.client.mock

Class MockBatchDeleter

java.lang.Object

org.apache.accumulo.core.client.impl.ScannerOptions

org.apache.accumulo.core.client.mock.MockScannerBase

org.apache.accumulo.core.client.mock.MockBatchScanner

org.apache.accumulo.core.client.mock.MockBatchDeleter

All Implemented Interfaces:

Iterable<Map.Entry<Key,Value>>, BatchDeleter, BatchScanner, ScannerBase

public class MockBatchDeleter
extends MockBatchScanner
implements BatchDeleter

BatchDeleter for a MockAccumulo instance. Behaves similarly to a regular BatchDeleter, with a few exceptions:

1. There is no waiting for memory to fill before flushing
2. Only one thread is used for writing

Otherwise, it behaves as expected.

Field Summary

Fields inherited from class org.apache.accumulo.core.client.mock.MockScannerBase

auths, table

Fields inherited from class org.apache.accumulo.core.client.impl.ScannerOptions

fetchedColumns, serverSideIteratorList, serverSideIteratorOptions, timeOut

Constructor Summary

Constructors

Constructor and Description
MockBatchDeleter(MockAccumulo acc, String tableName, Authorizations auths) Create a BatchDeleter for the specified instance on the specified table where the writer uses the specified Authorizations.

Method Summary

Modifier and Type	Method and Description
void	delete() Deletes the ranges specified by BatchDeleter.setRanges(java.util.Collection<org.apache.accumulo.core.data.Range>).

Methods inherited from class org.apache.accumulo.core.client.mock.MockBatchScanner

close, iterator, setRanges

Methods inherited from class org.apache.accumulo.core.client.mock.MockScannerBase

createFilter, getAuthorizations

Methods inherited from class org.apache.accumulo.core.client.impl.ScannerOptions

addScanIterator, clearColumns, clearScanIterators, fetchColumn, fetchColumn, fetchColumnFamily, getFetchedColumns, getTimeout, removeScanIterator, setOptions, setTimeout, updateScanIteratorOption

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.accumulo.core.client.BatchDeleter

close, setRanges

Methods inherited from interface org.apache.accumulo.core.client.ScannerBase

addScanIterator, clearColumns, clearScanIterators, fetchColumn, fetchColumn, fetchColumnFamily, getAuthorizations, getTimeout, iterator, removeScanIterator, setTimeout, updateScanIteratorOption

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.apache.accumulo.core.client.BatchScanner

setTimeout

Constructor Detail

MockBatchDeleter

public MockBatchDeleter(MockAccumulo acc,
                        String tableName,
                        Authorizations auths)

Create a BatchDeleter for the specified instance on the specified table where the writer uses the specified Authorizations.

Method Detail

delete

public void delete()
            throws MutationsRejectedException,
                   TableNotFoundException

Description copied from interface: BatchDeleter

Deletes the ranges specified by BatchDeleter.setRanges(java.util.Collection<org.apache.accumulo.core.data.Range>).

Specified by:

delete in interface BatchDeleter

Throws:

MutationsRejectedException - this can be thrown when deletion mutations fail

TableNotFoundException - when the table does not exist