io.stargate.db.cassandra.impl

Class StargateSystemKeyspace

java.lang.Object

io.stargate.db.cassandra.impl.StargateSystemKeyspace

public class StargateSystemKeyspace
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.cassandra.schema.TableMetadata	Local
static String	LOCAL_TABLE_NAME
static org.apache.cassandra.schema.TableMetadata	Peers
static String	PEERS_TABLE_NAME
static String	PEERS_V2_TABLE_NAME
static org.apache.cassandra.schema.TableMetadata	PeersV2
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 void	forceBlockingFlush(String... cfnames)
static Set<String>	generateRandomTokens(org.apache.cassandra.locator.InetAddressAndPort inetAddress, int numTokens)
static boolean	isSystemLocalOrPeers(org.apache.cassandra.cql3.CQLStatement statement)
static boolean	isSystemPeers(org.apache.cassandra.cql3.statements.SelectStatement statement)
static boolean	isSystemPeersV2(org.apache.cassandra.cql3.statements.SelectStatement statement)
static org.apache.cassandra.schema.KeyspaceMetadata	metadata()
static void	persistLocalMetadata()
static void	removeEndpoint(org.apache.cassandra.locator.InetAddressAndPort ep)
static org.apache.cassandra.schema.Tables	tables()
static void	updatePeerInfo(org.apache.cassandra.locator.InetAddressAndPort ep, String columnName, Object value)
static void	updatePeerNativeAddress(org.apache.cassandra.locator.InetAddressAndPort ep, org.apache.cassandra.locator.InetAddressAndPort address)

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

PEERS_V2_TABLE_NAME

public static final String PEERS_V2_TABLE_NAME

See Also:

Constant Field Values

SCHEMA_VERSION

public static final UUID SCHEMA_VERSION

Local

public static final org.apache.cassandra.schema.TableMetadata Local

Peers

public static final org.apache.cassandra.schema.TableMetadata Peers

PeersV2

public static final org.apache.cassandra.schema.TableMetadata PeersV2

Constructor Detail

StargateSystemKeyspace

public StargateSystemKeyspace()

Method Detail

tables

public static org.apache.cassandra.schema.Tables tables()

metadata

public static org.apache.cassandra.schema.KeyspaceMetadata metadata()

persistLocalMetadata

public static void persistLocalMetadata()

isSystemPeers

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

isSystemPeersV2

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

isSystemLocalOrPeers

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

updatePeerInfo

public static void updatePeerInfo(org.apache.cassandra.locator.InetAddressAndPort ep,
                                  String columnName,
                                  Object value)

updatePeerNativeAddress

public static void updatePeerNativeAddress(org.apache.cassandra.locator.InetAddressAndPort ep,
                                           org.apache.cassandra.locator.InetAddressAndPort address)

removeEndpoint

public static void removeEndpoint(org.apache.cassandra.locator.InetAddressAndPort ep)

forceBlockingFlush

public static void forceBlockingFlush(String... cfnames)

generateRandomTokens

public static Set<String> generateRandomTokens(org.apache.cassandra.locator.InetAddressAndPort inetAddress,
                                               int numTokens)