Class MockScanner
java.lang.Object
org.apache.accumulo.core.client.impl.ScannerOptions
org.apache.accumulo.core.client.mock.MockScannerBase
org.apache.accumulo.core.client.mock.MockScanner
- All Implemented Interfaces:
AutoCloseable,Iterable<Map.Entry<Key,,Value>> Scanner,ScannerBase
Deprecated.
since 1.8.0; use MiniAccumuloCluster or a standard mock framework instead.
-
Field Summary
Fields inherited from class org.apache.accumulo.core.client.mock.MockScannerBase
auths, tableFields inherited from class org.apache.accumulo.core.client.impl.ScannerOptions
batchTimeout, classLoaderContext, fetchedColumns, retryTimeout, serverSideIteratorList, serverSideIteratorOptions -
Method Summary
Modifier and TypeMethodDescriptionvoidDeprecated.Disables row isolation.voidDeprecated.Enables row isolation.intDeprecated.Returns the batch size (number of Key/Value pairs) that will be fetched at a time from a tablet server.getRange()Deprecated.Returns the range of keys to scan over.longDeprecated.The number of batches of Key/Value pairs returned before theScannerwill begin to prefetch the next batchintDeprecated.iterator()Deprecated.Returns an iterator over an accumulo table.voidsetBatchSize(int size) Deprecated.Sets the number of Key/Value pairs that will be fetched at a time from a tablet server.voidDeprecated.Sets the range of keys to scan over.voidsetReadaheadThreshold(long batches) Deprecated.Sets the number of batches of Key/Value pairs returned before theScannerwill begin to prefetch the next batchvoidsetTimeOut(int timeOut) Deprecated.Methods inherited from class org.apache.accumulo.core.client.mock.MockScannerBase
createFilter, getAuthorizations, setClassLoaderContextMethods inherited from class org.apache.accumulo.core.client.impl.ScannerOptions
addScanIterator, clearClassLoaderContext, clearColumns, clearSamplerConfiguration, clearScanIterators, close, fetchColumn, fetchColumn, fetchColumnFamily, getBatchTimeout, getClassLoaderContext, getFetchedColumns, getSamplerConfiguration, getTimeout, removeScanIterator, setBatchTimeout, setOptions, setSamplerConfiguration, setTimeout, updateScanIteratorOptionMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.lang.Iterable
forEach, spliteratorMethods inherited from interface org.apache.accumulo.core.client.ScannerBase
addScanIterator, clearClassLoaderContext, clearColumns, clearSamplerConfiguration, clearScanIterators, close, fetchColumn, fetchColumn, fetchColumnFamily, getAuthorizations, getBatchTimeout, getClassLoaderContext, getSamplerConfiguration, getTimeout, removeScanIterator, setBatchTimeout, setClassLoaderContext, setSamplerConfiguration, setTimeout, updateScanIteratorOption
-
Method Details
-
setTimeOut
Deprecated.Description copied from interface:ScannerThis setting determines how long a scanner will automatically retry when a failure occurs. By default a scanner will retry forever.- Specified by:
setTimeOutin interfaceScanner- Parameters:
timeOut- in seconds
-
getTimeOut
Deprecated.Description copied from interface:ScannerReturns the setting for how long a scanner will automatically retry when a failure occurs.- Specified by:
getTimeOutin interfaceScanner- Returns:
- the timeout configured for this scanner
-
setRange
Deprecated.Description copied from interface:ScannerSets the range of keys to scan over. -
getRange
Deprecated.Description copied from interface:ScannerReturns the range of keys to scan over. -
setBatchSize
public void setBatchSize(int size) Deprecated.Description copied from interface:ScannerSets the number of Key/Value pairs that will be fetched at a time from a tablet server.- Specified by:
setBatchSizein interfaceScanner- Parameters:
size- the number of Key/Value pairs to fetch per call to Accumulo
-
getBatchSize
public int getBatchSize()Deprecated.Description copied from interface:ScannerReturns the batch size (number of Key/Value pairs) that will be fetched at a time from a tablet server.- Specified by:
getBatchSizein interfaceScanner- Returns:
- the batch size configured for this scanner
-
enableIsolation
public void enableIsolation()Deprecated.Description copied from interface:ScannerEnables row isolation. Writes that occur to a row after a scan of that row has begun will not be seen if this option is enabled.- Specified by:
enableIsolationin interfaceScanner
-
disableIsolation
public void disableIsolation()Deprecated.Description copied from interface:ScannerDisables row isolation. Writes that occur to a row after a scan of that row has begun may be seen if this option is enabled.- Specified by:
disableIsolationin interfaceScanner
-
iterator
Deprecated.Description copied from interface:ScannerBaseReturns an iterator over an accumulo table. This iterator uses the options that are currently set for its lifetime, so setting options will have no effect on existing iterators.Keys returned by the iterator are not guaranteed to be in sorted order.
- Specified by:
iteratorin interfaceIterable<Map.Entry<Key,Value>> - Specified by:
iteratorin interfaceScannerBase- Overrides:
iteratorin classMockScannerBase- Returns:
- an iterator over Key,Value pairs which meet the restrictions set on the scanner
-
getReadaheadThreshold
public long getReadaheadThreshold()Deprecated.Description copied from interface:ScannerThe number of batches of Key/Value pairs returned before theScannerwill begin to prefetch the next batch- Specified by:
getReadaheadThresholdin interfaceScanner- Returns:
- Number of batches before read-ahead begins
-
setReadaheadThreshold
public void setReadaheadThreshold(long batches) Deprecated.Description copied from interface:ScannerSets the number of batches of Key/Value pairs returned before theScannerwill begin to prefetch the next batch- Specified by:
setReadaheadThresholdin interfaceScanner- Parameters:
batches- Non-negative number of batches
-