com.datastax.oss.dsbulk.partitioner.murmur3

Class Murmur3BulkTokenFactory

java.lang.Object

com.datastax.oss.driver.internal.core.metadata.token.Murmur3TokenFactory

com.datastax.oss.dsbulk.partitioner.murmur3.Murmur3BulkTokenFactory

All Implemented Interfaces:

com.datastax.oss.driver.internal.core.metadata.token.TokenFactory, BulkTokenFactory

public class Murmur3BulkTokenFactory
extends com.datastax.oss.driver.internal.core.metadata.token.Murmur3TokenFactory
implements BulkTokenFactory

A BulkTokenFactory for the Murmur3 Partitioner.

Field Summary

Fields

Modifier and Type	Field and Description
static BigInteger	TOTAL_TOKEN_COUNT

Fields inherited from class com.datastax.oss.driver.internal.core.metadata.token.Murmur3TokenFactory

MAX_TOKEN, MIN_TOKEN, PARTITIONER_NAME

Constructor Summary

Constructors

Constructor and Description
Murmur3BulkTokenFactory()

Method Summary

Modifier and Type	Method and Description
TokenRangeClusterer	clusterer() Returns a TokenRangeClusterer for the type of tokens managed by this token factory.
BulkTokenRange	range(Token start, Token end, Set<EndPoint> replicas) Creates a BulkTokenRange for the given start and end tokens.
TokenRangeSplitter	splitter() Returns a TokenRangeSplitter for the type of tokens managed by this token factory.
BigInteger	totalTokenCount()

Methods inherited from class com.datastax.oss.driver.internal.core.metadata.token.Murmur3TokenFactory

format, getPartitionerName, hash, minToken, parse, range

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastax.oss.dsbulk.partitioner.BulkTokenFactory

forPartitioner

Methods inherited from interface com.datastax.oss.driver.internal.core.metadata.token.TokenFactory

format, getPartitionerName, hash, minToken, parse, range

Field Detail

TOTAL_TOKEN_COUNT

public static final BigInteger TOTAL_TOKEN_COUNT

Constructor Detail

Murmur3BulkTokenFactory

public Murmur3BulkTokenFactory()

Method Detail

totalTokenCount

@NonNull
public BigInteger totalTokenCount()

Specified by:

totalTokenCount in interface BulkTokenFactory

Returns:

Total token count in a ring.

range

@NonNull
public BulkTokenRange range(@NonNull
                                     Token start,
                                     @NonNull
                                     Token end,
                                     @NonNull
                                     Set<EndPoint> replicas)

Description copied from interface: BulkTokenFactory

Creates a BulkTokenRange for the given start and end tokens.

Specified by:

range in interface BulkTokenFactory

splitter

@NonNull
public TokenRangeSplitter splitter()

Description copied from interface: BulkTokenFactory

Returns a TokenRangeSplitter for the type of tokens managed by this token factory.

Specified by:

splitter in interface BulkTokenFactory

clusterer

@NonNull
public TokenRangeClusterer clusterer()

Description copied from interface: BulkTokenFactory

Returns a TokenRangeClusterer for the type of tokens managed by this token factory.

Specified by:

clusterer in interface BulkTokenFactory