Package | Description |
---|---|
org.apache.cassandra.config | |
org.apache.cassandra.db | |
org.apache.cassandra.metrics | |
org.apache.cassandra.service | |
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
Table |
Schema.getTableInstance(java.lang.String tableName)
Get table instance by name
|
Table |
Schema.removeTableInstance(java.lang.String tableName)
Remove table from schema
|
Modifier and Type | Method and Description |
---|---|
void |
Schema.storeTableInstance(Table table)
Store given Table instance to the schema
|
Modifier and Type | Field and Description |
---|---|
Table |
ColumnFamilyStore.table |
Modifier and Type | Field and Description |
---|---|
static com.google.common.base.Function<java.lang.String,Table> |
Table.tableTransformer |
Modifier and Type | Method and Description |
---|---|
static Table |
Table.clear(java.lang.String table) |
static Table |
Table.clear(java.lang.String table,
Schema schema) |
static Table |
Table.open(java.lang.String table) |
static Table |
Table.openWithoutSSTables(java.lang.String table) |
Modifier and Type | Method and Description |
---|---|
static java.lang.Iterable<Table> |
Table.all() |
static java.lang.Iterable<Table> |
Table.nonSystem() |
static java.lang.Iterable<Table> |
Table.system() |
Modifier and Type | Method and Description |
---|---|
void |
ConsistencyLevel.assureSufficientLiveNodes(Table table,
java.lang.Iterable<java.net.InetAddress> liveEndpoints) |
int |
ConsistencyLevel.blockFor(Table table) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Table table,
java.lang.String columnFamily,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Table table,
java.lang.String columnFamily,
IPartitioner partitioner,
CFMetaData metadata) |
java.util.List<java.net.InetAddress> |
ConsistencyLevel.filterForQuery(Table table,
java.util.List<java.net.InetAddress> liveEndpoints) |
java.util.List<java.net.InetAddress> |
ConsistencyLevel.filterForQuery(Table table,
java.util.List<java.net.InetAddress> liveEndpoints,
ReadRepairDecision readRepair) |
abstract Row |
ReadCommand.getRow(Table table) |
Row |
SliceByNamesReadCommand.getRow(Table table) |
Row |
SliceFromReadCommand.getRow(Table table) |
boolean |
ConsistencyLevel.isSufficientLiveNodes(Table table,
java.lang.Iterable<java.net.InetAddress> liveEndpoints) |
Constructor and Description |
---|
KeyspaceMetrics(Table ks)
Creates metrics for given
ColumnFamilyStore . |
Modifier and Type | Field and Description |
---|---|
protected Table |
AbstractWriteResponseHandler.table |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.net.InetAddress> |
StorageService.getLiveNaturalEndpoints(Table table,
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(Table table,
RingPosition pos) |
Constructor and Description |
---|
AbstractWriteResponseHandler(Table table,
java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
java.lang.Runnable callback,
WriteType writeType) |
DatacenterSyncWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Table table,
java.lang.Runnable callback,
WriteType writeType) |
DatacenterWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Table table,
java.lang.Runnable callback,
WriteType writeType) |
WriteResponseHandler(java.util.Collection<java.net.InetAddress> writeEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Table table,
java.lang.Runnable callback,
WriteType writeType) |
Modifier and Type | Method and Description |
---|---|
static void |
StreamOut.transferRanges(java.net.InetAddress target,
Table table,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Stream the given ranges to the target endpoint from each CF in the given keyspace.
|
static void |
StreamOut.transferRanges(java.net.InetAddress target,
Table table,
java.lang.Iterable<ColumnFamilyStore> cfses,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Stream the given ranges to the target endpoint for provided CFs in the given keyspace.
|
Copyright © 2014 The Apache Software Foundation