Package org.apache.cassandra.schema

Class MigrationCoordinator

java.lang.Object

org.apache.cassandra.schema.MigrationCoordinator

public class MigrationCoordinator
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	IGNORED_ENDPOINTS_PROP
static java.lang.String	IGNORED_VERSIONS_PROP
static MigrationCoordinator	instance

Constructor Summary

Constructors

Constructor	Description
MigrationCoordinator()

Method Summary

Modifier and Type	Method	Description
boolean	awaitSchemaRequests(long waitMillis)	Wait until we've received schema responses for all versions we're aware of
int	getInflightTasks()
protected int	getMaxOutstandingVersionRequests()
protected org.apache.cassandra.schema.MigrationCoordinator.VersionInfo	getVersionInfoUnsafe(java.util.UUID version)
protected boolean	isAlive(InetAddressAndPort endpoint)
protected boolean	isLocalVersion(java.util.UUID version)
protected void	mergeSchemaFrom(InetAddressAndPort endpoint, java.util.Collection<Mutation> mutations)
java.util.Map<java.util.UUID,java.util.Set<InetAddressAndPort>>	outstandingVersions()
void	removeAndIgnoreEndpoint(InetAddressAndPort endpoint)
java.util.concurrent.Future<java.lang.Void>	reportEndpointVersion(InetAddressAndPort endpoint, java.util.UUID version)
java.util.concurrent.Future<java.lang.Void>	reportEndpointVersion(InetAddressAndPort endpoint, EndpointState state)
void	reset()
protected void	sendMigrationMessage(org.apache.cassandra.schema.MigrationCoordinator.Callback callback)
static void	setUptimeFn(java.util.function.LongSupplier supplier)
protected boolean	shouldPullFromEndpoint(InetAddressAndPort endpoint)
protected boolean	shouldPullImmediately(InetAddressAndPort endpoint, java.util.UUID version)
protected boolean	shouldPullSchema(java.util.UUID version)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

instance

public static final MigrationCoordinator instance

IGNORED_VERSIONS_PROP

public static final java.lang.String IGNORED_VERSIONS_PROP

See Also:

Constant Field Values

IGNORED_ENDPOINTS_PROP

public static final java.lang.String IGNORED_ENDPOINTS_PROP

See Also:

Constant Field Values

Constructor Detail

MigrationCoordinator

public MigrationCoordinator()

Method Detail

setUptimeFn

public static void setUptimeFn(java.util.function.LongSupplier supplier)

start

public void start()

reset

public void reset()

outstandingVersions

public java.util.Map<java.util.UUID,java.util.Set<InetAddressAndPort>> outstandingVersions()

getVersionInfoUnsafe

protected org.apache.cassandra.schema.MigrationCoordinator.VersionInfo getVersionInfoUnsafe(java.util.UUID version)

getMaxOutstandingVersionRequests

protected int getMaxOutstandingVersionRequests()

isAlive

protected boolean isAlive(InetAddressAndPort endpoint)

shouldPullSchema

protected boolean shouldPullSchema(java.util.UUID version)

shouldPullFromEndpoint

protected boolean shouldPullFromEndpoint(InetAddressAndPort endpoint)

shouldPullImmediately

protected boolean shouldPullImmediately(InetAddressAndPort endpoint,
                                        java.util.UUID version)

isLocalVersion

protected boolean isLocalVersion(java.util.UUID version)

reportEndpointVersion

public java.util.concurrent.Future<java.lang.Void> reportEndpointVersion(InetAddressAndPort endpoint,
                                                                         java.util.UUID version)

reportEndpointVersion

public java.util.concurrent.Future<java.lang.Void> reportEndpointVersion(InetAddressAndPort endpoint,
                                                                         EndpointState state)

removeAndIgnoreEndpoint

public void removeAndIgnoreEndpoint(InetAddressAndPort endpoint)

mergeSchemaFrom

protected void mergeSchemaFrom(InetAddressAndPort endpoint,
                               java.util.Collection<Mutation> mutations)

sendMigrationMessage

protected void sendMigrationMessage(org.apache.cassandra.schema.MigrationCoordinator.Callback callback)

getInflightTasks

public int getInflightTasks()

awaitSchemaRequests

public boolean awaitSchemaRequests(long waitMillis)

Wait until we've received schema responses for all versions we're aware of

Parameters:

waitMillis -

Returns:

true if response for all schemas were received, false if we timed out waiting