org.apache.accumulo.server.monitor.servlets.trace
Constructor and Description |
---|
NullScanner() |
Modifier and Type | Method and Description |
---|---|
void |
addScanIterator(IteratorSetting cfg)
Add a server-side scan iterator.
|
void |
clearColumns()
Clears the columns to be fetched (useful for resetting the scanner for reuse).
|
void |
clearScanIterators()
Clears scan iterators prior to returning a scanner to the pool.
|
void |
close()
Closes any underlying connections on the scanner
|
void |
disableIsolation()
Disables row isolation.
|
void |
enableIsolation()
Enables row isolation.
|
void |
fetchColumn(org.apache.hadoop.io.Text colFam,
org.apache.hadoop.io.Text colQual)
Adds a column to the list of columns that will be fetched by this scanner.
|
void |
fetchColumnFamily(org.apache.hadoop.io.Text col)
Adds a column family to the list of columns that will be fetched by this scanner.
|
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()
Deprecated.
|
long |
getTimeout(TimeUnit timeUnit)
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 |
removeScanIterator(String iteratorName)
Remove an iterator from the list of iterators.
|
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)
Deprecated.
|
void |
setTimeout(long timeOut,
TimeUnit timeUnit)
This setting determines how long a scanner will automatically retry when a failure occurs.
|
void |
updateScanIteratorOption(String iteratorName,
String key,
String value)
Update the options for an iterator.
|
public void addScanIterator(IteratorSetting cfg)
ScannerBase
addScanIterator
in interface ScannerBase
cfg
- fully specified scan-time iterator, including all options for the iterator. Any changes to the iterator setting after this call are not propagated
to the stored iterator.public void updateScanIteratorOption(String iteratorName, String key, String value)
ScannerBase
updateScanIteratorOption
in interface ScannerBase
iteratorName
- the name of the iterator to changekey
- the name of the optionvalue
- the new value for the named optionpublic void fetchColumnFamily(org.apache.hadoop.io.Text col)
ScannerBase
fetchColumnFamily
in interface ScannerBase
col
- the column family to be fetchedpublic void fetchColumn(org.apache.hadoop.io.Text colFam, org.apache.hadoop.io.Text colQual)
ScannerBase
fetchColumn
in interface ScannerBase
colFam
- the column family of the column to be fetchedcolQual
- the column qualifier of the column to be fetchedpublic void clearColumns()
ScannerBase
clearColumns
in interface ScannerBase
public void clearScanIterators()
ScannerBase
clearScanIterators
in interface ScannerBase
@Deprecated public void setTimeOut(int timeOut)
Scanner
setTimeOut
in interface Scanner
timeOut
- in seconds@Deprecated public 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
public Iterator<Map.Entry<Key,Value>> iterator()
ScannerBase
public void removeScanIterator(String iteratorName)
ScannerBase
removeScanIterator
in interface ScannerBase
iteratorName
- nickname used for the iteratorpublic void setTimeout(long timeOut, TimeUnit timeUnit)
ScannerBase
setTimeout
in interface ScannerBase
timeUnit
- determines how timeout is interpretedpublic long getTimeout(TimeUnit timeUnit)
ScannerBase
getTimeout
in interface ScannerBase
public void close()
ScannerBase
close
in interface ScannerBase
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.