Package org.apache.cassandra.dht

Class BootStrapper

java.lang.Object

org.apache.cassandra.utils.progress.ProgressEventNotifierSupport

org.apache.cassandra.dht.BootStrapper

All Implemented Interfaces:

ProgressEventNotifier

public class BootStrapper
extends ProgressEventNotifierSupport

Field Summary

Fields

Modifier and Type	Field	Description
protected final InetAddressAndPort	address
protected final TokenMetadata	tokenMetadata
protected final Collection<Token>	tokens

Constructor Summary

Constructors

Constructor	Description
BootStrapper(InetAddressAndPort address, Collection<Token> tokens, TokenMetadata tmd)

Method Summary

Modifier and Type	Method	Description
Future<StreamState>	bootstrap(StreamStateStore stateStore, boolean useStrictConsistency)
static Collection<Token>	getBootstrapTokens(TokenMetadata metadata, InetAddressAndPort address, long schemaTimeoutMillis, long ringTimeoutMillis)	if initialtoken was specified, use that (split on comma).
static Collection<Token>	getRandomTokens(TokenMetadata metadata, int numTokens)

Methods inherited from class org.apache.cassandra.utils.progress.ProgressEventNotifierSupport

addProgressListener, fireProgressEvent, removeProgressListener

Methods inherited from class java.lang.Object

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

Field Details

address

protected final InetAddressAndPort address

tokens

protected final Collection<Token> tokens

tokenMetadata

protected final TokenMetadata tokenMetadata

Constructor Details

BootStrapper

public BootStrapper(InetAddressAndPort address,
 Collection<Token> tokens,
 TokenMetadata tmd)

Method Details

bootstrap

public Future<StreamState> bootstrap(StreamStateStore stateStore,
 boolean useStrictConsistency)

getBootstrapTokens

public static Collection<Token> getBootstrapTokens(TokenMetadata metadata,
 InetAddressAndPort address,
 long schemaTimeoutMillis,
 long ringTimeoutMillis)
                                            throws ConfigurationException

if initialtoken was specified, use that (split on comma). otherwise, if allocationKeyspace is specified use the token allocation algorithm to generate suitable tokens else choose num_tokens tokens at random

Throws:

ConfigurationException

getRandomTokens

public static Collection<Token> getRandomTokens(TokenMetadata metadata,
 int numTokens)