Class SimpleScanDispatcher
- java.lang.Object
-
- org.apache.accumulo.core.spi.scan.SimpleScanDispatcher
-
- All Implemented Interfaces:
ScanDispatcher
public class SimpleScanDispatcher extends Object implements ScanDispatcher
If no options are given, then this will default to an executor nameddefault
andScanDirectives.CacheUsage.TABLE
for index and data cache. This dispatcher supports the following options.table.scan.dispatcher.opts.executor=<scan executor name>
: dispatches all scans to the named executor.table.scan.dispatcher.opts.multi_executor=<scan executor name>
: dispatches batch scans to the named executor.table.scan.dispatcher.opts.single_executor=<scan executor name>
: dispatches regular scans to the named executor.table.scan.dispatcher.opts.executor.<type>=<scan executor name>
: dispatches scans that set the hintscan_type=<type>
to the named executor. If this setting matches then it takes precedence over all other settings. SeeScannerBase.setExecutionHints(Map)
table.scan.dispatcher.opts.cacheUsage.<type>[.index|.data]=enabled|disabled|opportunistic|table
: for scans that set the hintscan_type=<type>
determines how the scan will use cache.
multi_executor
andsingle_executor
options override theexecutor
option.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.accumulo.core.spi.scan.ScanDispatcher
ScanDispatcher.DispatchParameters, ScanDispatcher.DispatchParmaters, ScanDispatcher.InitParameters
-
-
Field Summary
Fields Modifier and Type Field Description static String
DEFAULT_SCAN_EXECUTOR_NAME
-
Constructor Summary
Constructors Constructor Description SimpleScanDispatcher()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ScanDirectives
dispatch(ScanDispatcher.DispatchParameters params)
Accumulo calls this method for each scan batch to determine what executor to use and how to utilize cache for the scan.void
init(ScanDispatcher.InitParameters params)
This method is called once after a ScanDispatcher is instantiated.-
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.spi.scan.ScanDispatcher
dispatch
-
-
-
-
Field Detail
-
DEFAULT_SCAN_EXECUTOR_NAME
public static final String DEFAULT_SCAN_EXECUTOR_NAME
- See Also:
- Constant Field Values
-
-
Method Detail
-
init
public void init(ScanDispatcher.InitParameters params)
Description copied from interface:ScanDispatcher
This method is called once after a ScanDispatcher is instantiated.- Specified by:
init
in interfaceScanDispatcher
-
dispatch
public ScanDirectives dispatch(ScanDispatcher.DispatchParameters params)
Description copied from interface:ScanDispatcher
Accumulo calls this method for each scan batch to determine what executor to use and how to utilize cache for the scan.- Specified by:
dispatch
in interfaceScanDispatcher
-
-