Package | Description |
---|---|
org.apache.cassandra.config | |
org.apache.cassandra.db | |
org.apache.cassandra.db.view | |
org.apache.cassandra.metrics | |
org.apache.cassandra.service |
Modifier and Type | Method and Description |
---|---|
Keyspace |
Schema.getKeyspaceInstance(java.lang.String keyspaceName)
Get keyspace instance by name
|
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
|
Modifier and Type | Field and Description |
---|---|
Keyspace |
ColumnFamilyStore.keyspace |
Modifier and Type | Field and Description |
---|---|
static com.google.common.base.Function<java.lang.String,Keyspace> |
Keyspace.keyspaceTransformer |
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.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 |
---|---|
void |
ConsistencyLevel.assureSufficientLiveNodes(Keyspace keyspace,
java.lang.Iterable<java.net.InetAddress> liveEndpoints) |
int |
ConsistencyLevel.blockFor(Keyspace keyspace) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
CFMetaData metadata,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
CFMetaData metadata,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
CFMetaData metadata,
Directories directories,
boolean loadSSTables,
boolean registerBookkeeping,
boolean offline)
This is only directly used by offline tools
|
java.util.List<java.net.InetAddress> |
ConsistencyLevel.filterForQuery(Keyspace keyspace,
java.util.List<java.net.InetAddress> liveEndpoints) |
java.util.List<java.net.InetAddress> |
ConsistencyLevel.filterForQuery(Keyspace keyspace,
java.util.List<java.net.InetAddress> liveEndpoints,
ReadRepairDecision readRepair) |
boolean |
ConsistencyLevel.isSufficientLiveNodes(Keyspace keyspace,
java.lang.Iterable<java.net.InetAddress> liveEndpoints) |
Constructor and Description |
---|
ColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamilyName,
int generation,
CFMetaData metadata,
Directories directories,
boolean loadSSTables,
boolean registerBookeeping,
boolean offline) |
Constructor and Description |
---|
ViewManager(Keyspace keyspace) |
Constructor and Description |
---|
KeyspaceMetrics(Keyspace ks)
Creates metrics for given
ColumnFamilyStore . |
Modifier and Type | Field and Description |
---|---|
protected Keyspace |
AbstractWriteResponseHandler.keyspace |
protected Keyspace |
ResponseResolver.keyspace |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.net.InetAddress> |
StorageService.getLiveNaturalEndpoints(Keyspace keyspace,
java.nio.ByteBuffer key)
This method attempts to return N endpoints that are responsible for storing the
specified key i.e for replication.
|
java.util.List<java.net.InetAddress> |
StorageService.getLiveNaturalEndpoints(Keyspace keyspace,
RingPosition pos) |
void |
StorageService.getLiveNaturalEndpoints(Keyspace keyspace,
RingPosition pos,
java.util.List<java.net.InetAddress> liveEps)
This method attempts to return N endpoints that are responsible for storing the
specified key i.e for replication.
|
static java.util.List<java.net.InetAddress> |
StorageProxy.getLiveSortedEndpoints(Keyspace keyspace,
java.nio.ByteBuffer key) |
static java.util.List<java.net.InetAddress> |
StorageProxy.getLiveSortedEndpoints(Keyspace keyspace,
RingPosition pos) |
Constructor and Description |
---|
AbstractWriteResponseHandler(Keyspace keyspace,
java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DatacenterSyncWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DatacenterWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DigestResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
NeverSpeculatingReadExecutor(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistencyLevel,
java.util.List<java.net.InetAddress> targetReplicas,
long queryStartNanoTime) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
int blockfor,
ReadCommand command,
Keyspace keyspace,
java.util.List<java.net.InetAddress> endpoints,
long queryStartNanoTime) |
ResponseResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
WriteResponseHandler(java.util.Collection<java.net.InetAddress> writeEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
Copyright © 2020 The Apache Software Foundation