io.stargate.db.dse.impl

Class StargateSystemKeyspace

java.lang.Object

io.stargate.db.dse.impl.StargateSystemKeyspace

public class StargateSystemKeyspace
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static StargateSystemKeyspace	instance
static String	LOCAL_TABLE_NAME
static String	PEERS_TABLE_NAME
static UUID	SCHEMA_VERSION
static String	SYSTEM_KEYSPACE_NAME

Constructor Summary

Constructors

Constructor and Description
StargateSystemKeyspace()

Method Summary

Modifier and Type	Method and Description
static Set<String>	generateRandomTokens(InetAddress inetAddress, int numTokens)
StargateLocalInfo	getLocal()
ConcurrentMap<InetAddress,StargatePeerInfo>	getPeers()
static void	initialize()
static boolean	isSystemLocal(org.apache.cassandra.cql3.statements.SelectStatement statement)
static boolean	isSystemLocalOrPeers(org.apache.cassandra.cql3.CQLStatement statement)
void	persistLocalMetadata()
static org.apache.cassandra.schema.TableMetadata	virtualFromLegacy(org.apache.cassandra.schema.TableMetadata legacy, String table)

Methods inherited from class java.lang.Object

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

Field Detail

SYSTEM_KEYSPACE_NAME

public static final String SYSTEM_KEYSPACE_NAME

See Also:

Constant Field Values

LOCAL_TABLE_NAME

public static final String LOCAL_TABLE_NAME

See Also:

Constant Field Values

PEERS_TABLE_NAME

public static final String PEERS_TABLE_NAME

See Also:

Constant Field Values

SCHEMA_VERSION

public static final UUID SCHEMA_VERSION

instance

public static final StargateSystemKeyspace instance

Constructor Detail

StargateSystemKeyspace

public StargateSystemKeyspace()

Method Detail

getPeers

public ConcurrentMap<InetAddress,StargatePeerInfo> getPeers()

getLocal

public StargateLocalInfo getLocal()

persistLocalMetadata

public void persistLocalMetadata()

isSystemLocal

public static boolean isSystemLocal(org.apache.cassandra.cql3.statements.SelectStatement statement)

isSystemLocalOrPeers

public static boolean isSystemLocalOrPeers(org.apache.cassandra.cql3.CQLStatement statement)

initialize

public static void initialize()

virtualFromLegacy

public static org.apache.cassandra.schema.TableMetadata virtualFromLegacy(org.apache.cassandra.schema.TableMetadata legacy,
                                                                          String table)

generateRandomTokens

public static Set<String> generateRandomTokens(InetAddress inetAddress,
                                               int numTokens)