com.datastax.oss.dsbulk.workflow.commons.policies.lbp

Class SimpleNodeFilter

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.policies.lbp.SimpleNodeFilter

All Implemented Interfaces:

Predicate<Node>

public class SimpleNodeFilter
extends Object
implements Predicate<Node>

DSSBulk's default node filter. It operates on two distinct lists: one for nodes to explicitly allow, and one for nodes to explicitly deny.

If both lists are empty, all nodes are accepted. If the allow list is not empty, only nodes in that list will be allowed. If the deny list is not empty, only nodes not in that list will be allowed.

Usually just one of the two lists would be non-empty, but the filter also functions properly when both are non-empty, in which case the deny list wins. In other words, if a node appears in both lists, it will be excluded.

Nodes are resolved eagerly during startup and are not re-resolved after.

This filter is not compatible with DataStax Astra cloud deployments.

See Also:

BulkDriverOption.LOAD_BALANCING_POLICY_FILTER_ALLOW, BulkDriverOption.LOAD_BALANCING_POLICY_FILTER_DENY

Constructor Summary

Constructors

Constructor and Description
SimpleNodeFilter(DriverContext context, String profileName) Constructor required by the driver to create an instance of this filter.
SimpleNodeFilter(Set<EndPoint> includedHosts, Set<EndPoint> excludedHosts)

Method Summary

Modifier and Type	Method and Description
boolean	test(Node node)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Predicate

and, isEqual, negate, or

Constructor Detail

SimpleNodeFilter

public SimpleNodeFilter(DriverContext context,
                        String profileName)

Constructor required by the driver to create an instance of this filter.

Parameters:

context - The driver context to get the configuration from.

profileName - The execution profile name; for DSBulk, this should always be the default profile name.

SimpleNodeFilter

public SimpleNodeFilter(Set<EndPoint> includedHosts,
                        Set<EndPoint> excludedHosts)

Method Detail

test

public boolean test(Node node)

Specified by:

test in interface Predicate<Node>