Package org.apache.accumulo.core.spi.scan
package org.apache.accumulo.core.spi.scan
-
ClassDescriptionExtension of the
ConfigurableScanServerSelector
that can be used when there are multiple ScanServers running on the same host and for some reason, like using a shared off-heap cache, sending scans for the same tablet to the same host may provide a better experience.The default Accumulo selector for scan servers.When configured for a scan executor, this prioritizer allows scanners to set priorities as integers.Prioritize scans based on the ratio of runTime/idleTime.Encapsulates information about how a scan should be executed.Communicates how a scan should use cache.A per table scan dispatcher that decides which executor should be used to process a scan.The method parameters forScanDispatcher.dispatch(DispatchParameters)
.Deprecated.The method parameters forScanDispatcher.init(InitParameters)
.Interface for obtaining information about a scan executorProvides information about an active Accumulo scan against a tablet.A factory for creating comparators used for prioritizing scans.The method parameters forScanPrioritizer.createComparator(CreateParameters)
.This object is used to communicate what previous actions were attempted, when they were attempted, and the result of those attemptsInformation about a scan server.Returned byScanServerSelector.selectServers(ScanServerSelector.SelectorParameters)
to specify what scan servers to use and how to use them.A client side plugin that determines what scan servers to use for eventually consistent scans.This interface exists so that is easier to evolve what is passed toScanServerSelector.init(InitParameters)
without having to make breaking changes.This interface exists so that is easier to evolve what is passed toScanServerSelector.selectServers(SelectorParameters)
without having to make breaking changes.If no options are given, then this will default to an executor nameddefault
andScanDispatch.CacheUsage.TABLE
for index and data cache.
ScanDispatcher.DispatchParameters
andScanDispatcher.dispatch(DispatchParameters)