Modifier and Type | Field and Description |
---|---|
Keyspace |
ColumnFamilyStore.keyspace |
Modifier and Type | Method and Description |
---|---|
static Keyspace |
Keyspace.clear(java.lang.String keyspaceName) |
static Keyspace |
Keyspace.clear(java.lang.String keyspaceName,
Schema schema) |
static Keyspace |
Keyspace.mockKS(KeyspaceMetadata metadata) |
static Keyspace |
Keyspace.open(java.lang.String keyspaceName) |
static Keyspace |
Keyspace.openWithoutSSTables(java.lang.String keyspaceName) |
Modifier and Type | Method and Description |
---|---|
static java.lang.Iterable<Keyspace> |
Keyspace.all() |
static java.util.stream.Stream<Keyspace> |
Keyspace.allExisting() |
static java.lang.Iterable<Keyspace> |
Keyspace.nonLocalStrategy() |
static java.lang.Iterable<Keyspace> |
Keyspace.nonSystem() |
static java.lang.Iterable<Keyspace> |
Keyspace.system() |
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
TableMetadataRef metadata,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
TableMetadataRef metadata,
Directories directories,
boolean loadSSTables,
boolean registerBookkeeping,
boolean offline)
This is only directly used by offline tools
|
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
TableMetadataRef metadata,
boolean loadSSTables) |
Constructor and Description |
---|
CassandraKeyspaceWriteHandler(Keyspace keyspace) |
ColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamilyName,
int generation,
TableMetadataRef metadata,
Directories directories,
boolean loadSSTables,
boolean registerBookeeping,
boolean offline) |
Constructor and Description |
---|
CassandraKeyspaceRepairManager(Keyspace keyspace) |
Constructor and Description |
---|
ViewManager(Keyspace keyspace) |
Modifier and Type | Field and Description |
---|---|
protected Keyspace |
ReplicaPlan.keyspace |
Modifier and Type | Method and Description |
---|---|
Keyspace |
ReplicaPlan.keyspace() |
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forForwardingCounterWrite(Keyspace keyspace,
Token token,
Replica replica)
A forwarding counter write is always sent to a single owning coordinator for the range, by the original coordinator
(if it is not itself an owner)
|
static ReplicaPlan.ForPaxosWrite |
ReplicaPlans.forPaxos(Keyspace keyspace,
DecoratedKey key,
ConsistencyLevel consistencyForPaxos)
Construct the plan for a paxos round - NOT the write or read consistency level for either the write or comparison,
but for the paxos linearisation agreement.
|
static ReplicaPlan.ForRangeRead |
ReplicaPlans.forRangeRead(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
AbstractBounds<PartitionPosition> range,
int vnodeCount)
Construct a plan for reading the provided range at the provided consistency level.
|
static ReplicaPlan.ForTokenRead |
ReplicaPlans.forRead(Keyspace keyspace,
Token token,
ConsistencyLevel consistencyLevel,
SpeculativeRetryPolicy retry)
Construct a plan for reading the provided token at the provided consistency level.
|
static ReplicaPlan.ForRangeRead |
ReplicaPlans.forSingleReplicaRead(Keyspace keyspace,
AbstractBounds<PartitionPosition> range,
Replica replica,
int vnodeCount)
Construct a plan for reading from a single node - this permits no speculation or read-repair
|
static ReplicaPlan.ForTokenRead |
ReplicaPlans.forSingleReplicaRead(Keyspace keyspace,
Token token,
Replica replica)
Construct a plan for reading from a single node - this permits no speculation or read-repair
|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forSingleReplicaWrite(Keyspace keyspace,
Token token,
Replica replica)
Construct a ReplicaPlan for writing to exactly one node, with CL.ONE.
|
static ReplicaLayout.ForTokenWrite |
ReplicaLayout.forTokenWriteLiveAndDown(Keyspace keyspace,
Token token)
Gets the 'natural' and 'pending' replicas that own a given token, with no filtering or processing.
|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
EndpointsForToken natural,
EndpointsForToken pending,
java.util.function.Predicate<Replica> isAlive,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaLayout.ForTokenWrite liveAndDown,
ReplicaLayout.ForTokenWrite live,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaLayout.ForTokenWrite liveAndDown,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
Token token,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForRangeRead |
ReplicaPlans.maybeMerge(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaPlan.ForRangeRead left,
ReplicaPlan.ForRangeRead right)
Take two range read plans for adjacent ranges, and check if it is OK (and worthwhile) to combine them into a single plan
|
Constructor and Description |
---|
ForRangeRead(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
AbstractBounds<PartitionPosition> range,
EndpointsForRange candidates,
EndpointsForRange contact,
int vnodeCount) |
ForTokenRead(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
EndpointsForToken candidates,
EndpointsForToken contacts) |
ForTokenWrite(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
EndpointsForToken pending,
EndpointsForToken liveAndDown,
EndpointsForToken live,
EndpointsForToken contact) |
Constructor and Description |
---|
KeyspaceMetrics(Keyspace ks)
Creates metrics for given
ColumnFamilyStore . |
Modifier and Type | Method and Description |
---|---|
Keyspace |
Schema.getKeyspaceInstance(java.lang.String keyspaceName)
Get keyspace instance by name
|
Keyspace |
SchemaProvider.getKeyspaceInstance(java.lang.String keyspaceName) |
Keyspace |
Schema.removeKeyspaceInstance(java.lang.String keyspaceName)
Remove keyspace from schema
|
Modifier and Type | Method and Description |
---|---|
void |
Schema.storeKeyspaceInstance(Keyspace keyspace)
Store given Keyspace instance to the schema
|
void |
SchemaProvider.storeKeyspaceInstance(Keyspace keyspace) |
Modifier and Type | Method and Description |
---|---|
Keyspace |
ActiveRepairService.ParentRepairSession.getKeyspace() |
Copyright © 2009-2022 The Apache Software Foundation