Package org.apache.accumulo.core.spi.scan

Class ConfigurableScanServerHostSelector

java.lang.Object

org.apache.accumulo.core.spi.scan.ConfigurableScanServerSelector

org.apache.accumulo.core.spi.scan.ConfigurableScanServerHostSelector

All Implemented Interfaces:

ScanServerSelector

public class ConfigurableScanServerHostSelector
extends ConfigurableScanServerSelector

Extension 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. This implementation will initially hash a Tablet to a ScanServer. If the ScanServer is unable to execute the scan, this implementation will try to send the scan to a ScanServer on the same host. If there are no more ScanServers to try on that host, then it will fall back to trying a different host and the process repeats.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.accumulo.core.spi.scan.ConfigurableScanServerSelector

ConfigurableScanServerSelector.Profile

Nested classes/interfaces inherited from interface org.apache.accumulo.core.spi.scan.ScanServerSelector

ScanServerSelector.InitParameters, ScanServerSelector.SelectorParameters

Field Summary

Fields inherited from class org.apache.accumulo.core.spi.scan.ConfigurableScanServerSelector

PROFILES_DEFAULT, RANDOM

Fields inherited from interface org.apache.accumulo.core.spi.scan.ScanServerSelector

DEFAULT_SCAN_SERVER_GROUP_NAME

Constructor Summary

Constructors

Constructor	Description
ConfigurableScanServerHostSelector()

Method Summary

Modifier and Type	Method	Description
protected int	selectServers(ScanServerSelector.SelectorParameters params, ConfigurableScanServerSelector.Profile profile, List<String> orderedScanServers, Map<TabletId,String> serversToUse)

Methods inherited from class org.apache.accumulo.core.spi.scan.ConfigurableScanServerSelector

init, selectServers

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ConfigurableScanServerHostSelector

public ConfigurableScanServerHostSelector()

Method Details

selectServers

protected int selectServers(ScanServerSelector.SelectorParameters params,
 ConfigurableScanServerSelector.Profile profile,
 List<String> orderedScanServers,
 Map<TabletId,String> serversToUse)

Overrides:

selectServers in class ConfigurableScanServerSelector