public class IsolatedScanner extends org.apache.accumulo.core.client.impl.ScannerOptions implements Scanner
Modifier and Type | Class and Description |
---|---|
static class |
IsolatedScanner.MemoryRowBuffer |
static class |
IsolatedScanner.MemoryRowBufferFactory |
static interface |
IsolatedScanner.RowBuffer |
static interface |
IsolatedScanner.RowBufferFactory |
Constructor and Description |
---|
IsolatedScanner(Scanner scanner) |
IsolatedScanner(Scanner scanner,
IsolatedScanner.RowBufferFactory bufferFactory) |
Modifier and Type | Method and Description |
---|---|
void |
disableIsolation()
Disables row isolation.
|
void |
enableIsolation()
Enables row isolation.
|
int |
getBatchSize()
Returns the batch size (number of Key/Value pairs) that will be fetched at a time from a tablet server.
|
Range |
getRange()
Returns the range of keys to scan over.
|
int |
getTimeOut()
Returns the setting for how long a scanner will automatically retry when a failure occurs.
|
Iterator<Map.Entry<Key,Value>> |
iterator()
Returns an iterator over an accumulo table.
|
void |
setBatchSize(int size)
Sets the number of Key/Value pairs that will be fetched at a time from a tablet server.
|
void |
setRange(Range range)
Sets the range of keys to scan over.
|
void |
setTimeOut(int timeOut)
This setting determines how long a scanner will automatically retry when a failure occurs.
|
addScanIterator, clearColumns, clearScanIterators, fetchColumn, fetchColumn, fetchColumnFamily, getFetchedColumns, removeScanIterator, setColumnFamilyRegex, setColumnQualifierRegex, setOptions, setRowRegex, setScanIteratorOption, setScanIterators, setupRegex, setValueRegex, updateScanIteratorOption
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addScanIterator, clearColumns, clearScanIterators, fetchColumn, fetchColumnFamily, removeScanIterator, setColumnFamilyRegex, setColumnQualifierRegex, setRowRegex, setScanIteratorOption, setScanIterators, setupRegex, setValueRegex, updateScanIteratorOption
public IsolatedScanner(Scanner scanner)
public IsolatedScanner(Scanner scanner, IsolatedScanner.RowBufferFactory bufferFactory)
public Iterator<Map.Entry<Key,Value>> iterator()
ScannerBase
public void setTimeOut(int timeOut)
Scanner
setTimeOut
in interface Scanner
timeOut
- in secondspublic int getTimeOut()
Scanner
getTimeOut
in interface Scanner
public void setRange(Range range)
Scanner
public Range getRange()
Scanner
public void setBatchSize(int size)
Scanner
setBatchSize
in interface Scanner
size
- the number of Key/Value pairs to fetch per call to Accumulopublic int getBatchSize()
Scanner
getBatchSize
in interface Scanner
public void enableIsolation()
Scanner
enableIsolation
in interface Scanner
public void disableIsolation()
Scanner
disableIsolation
in interface Scanner
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.