Modifier and Type | Field and Description |
---|---|
static CFMetaData |
CFMetaData.BatchlogCf |
static CFMetaData |
CFMetaData.CompactionHistoryCf |
static CFMetaData |
CFMetaData.CompactionLogCf |
static CFMetaData |
CFMetaData.CounterIdCf |
static CFMetaData |
CFMetaData.HintsCf |
static CFMetaData |
CFMetaData.IndexCf |
static CFMetaData |
CFMetaData.LocalCf |
static CFMetaData |
CFMetaData.PaxosCf |
static CFMetaData |
CFMetaData.PeerEventsCf |
static CFMetaData |
CFMetaData.PeersCf |
static CFMetaData |
CFMetaData.RangeXfersCf |
static CFMetaData |
CFMetaData.SchemaColumnFamiliesCf |
static CFMetaData |
CFMetaData.SchemaColumnsCf |
static CFMetaData |
CFMetaData.SchemaKeyspacesCf |
static CFMetaData |
CFMetaData.SchemaTriggersCf |
static CFMetaData |
CFMetaData.SSTableActivityCF |
static CFMetaData |
CFMetaData.TraceEventsCf |
static CFMetaData |
CFMetaData.TraceSessionsCf |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
CFMetaData.bloomFilterFpChance(java.lang.Double prop) |
CFMetaData |
CFMetaData.caching(CFMetaData.Caching prop) |
CFMetaData |
CFMetaData.clone() |
CFMetaData |
CFMetaData.columnMetadata(java.util.Map<java.nio.ByteBuffer,ColumnDefinition> prop) |
CFMetaData |
CFMetaData.comment(java.lang.String prop) |
CFMetaData |
CFMetaData.compactionStrategyClass(java.lang.Class<? extends AbstractCompactionStrategy> prop) |
CFMetaData |
CFMetaData.compactionStrategyOptions(java.util.Map<java.lang.String,java.lang.String> prop) |
static CFMetaData |
CFMetaData.compile(java.lang.String cql,
java.lang.String keyspace) |
CFMetaData |
CFMetaData.compressionParameters(CompressionParameters prop) |
CFMetaData |
CFMetaData.dcLocalReadRepairChance(double prop) |
CFMetaData |
CFMetaData.defaultTimeToLive(int prop) |
CFMetaData |
CFMetaData.defaultValidator(AbstractType<?> prop) |
CFMetaData |
CFMetaData.droppedColumns(java.util.Map<java.nio.ByteBuffer,java.lang.Long> cols) |
static CFMetaData |
CFMetaData.fromSchema(UntypedResultSet.Row result)
Deserialize CF metadata from low-level representation
|
static CFMetaData |
CFMetaData.fromThrift(CfDef cf_def) |
static CFMetaData |
CFMetaData.fromThriftCqlRow(CqlRow row)
Create CFMetaData from thrift
CqlRow that contains columns from schema_columnfamilies. |
CFMetaData |
CFMetaData.gcGraceSeconds(int prop) |
CFMetaData |
Schema.getCFMetaData(Descriptor descriptor) |
CFMetaData |
Schema.getCFMetaData(java.lang.String keyspaceName,
java.lang.String cfName)
Given a keyspace name & column family name, get the column family
meta data.
|
CFMetaData |
Schema.getCFMetaData(java.util.UUID cfId)
Get ColumnFamily metadata by its identifier
|
CFMetaData |
CFMetaData.indexInterval(int prop) |
CFMetaData |
CFMetaData.keyValidator(AbstractType<?> prop) |
CFMetaData |
CFMetaData.maxCompactionThreshold(int prop) |
CFMetaData |
CFMetaData.memtableFlushPeriod(int prop) |
CFMetaData |
CFMetaData.minCompactionThreshold(int prop) |
static CFMetaData |
CFMetaData.newIndexMetadata(CFMetaData parent,
ColumnDefinition info,
AbstractType<?> columnComparator) |
CFMetaData |
CFMetaData.populateIoCacheOnFlush(boolean prop) |
CFMetaData |
CFMetaData.readRepairChance(double prop) |
CFMetaData |
CFMetaData.rebuild() |
CFMetaData |
CFMetaData.reloadSecondaryIndexMetadata(CFMetaData parent) |
static CFMetaData |
CFMetaData.rename(CFMetaData cfm,
java.lang.String newName) |
CFMetaData |
CFMetaData.replicateOnWrite(boolean prop) |
CFMetaData |
CFMetaData.speculativeRetry(CFMetaData.SpeculativeRetry prop) |
CFMetaData |
CFMetaData.triggers(java.util.Map<java.lang.String,TriggerDefinition> prop) |
CFMetaData |
CFMetaData.validate() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,CFMetaData> |
KSMetaData.cfMetaData() |
static java.util.Map<java.lang.String,CFMetaData> |
KSMetaData.deserializeColumnFamilies(Row row)
Deserialize ColumnFamilies from low-level schema representation, all of them belong to the same keyspace
|
java.util.Map<java.lang.String,CFMetaData> |
Schema.getKeyspaceMetaData(java.lang.String keyspaceName)
Get metadata about keyspace inner ColumnFamilies
|
Modifier and Type | Method and Description |
---|---|
void |
CFMetaData.apply(CFMetaData cfm)
Updates CFMetaData in-place to match cf_def
*Note*: This method left public only for DefsTest, don't use directly!
|
static java.util.List<ColumnDefinition> |
ColumnDefinition.fromSchema(Row serializedColumns,
CFMetaData cfm)
Deserialize columns from storage-level representation
|
static KSMetaData |
KSMetaData.fromThrift(KsDef ksd,
CFMetaData... cfDefs) |
void |
Schema.load(CFMetaData cfm)
Load individual ColumnFamily Definition to the schema
(to make ColumnFamily lookup faster)
|
static CFMetaData |
CFMetaData.newIndexMetadata(CFMetaData parent,
ColumnDefinition info,
AbstractType<?> columnComparator) |
void |
Schema.purge(CFMetaData cfm)
Used for ColumnFamily data eviction out from the schema
|
CFMetaData |
CFMetaData.reloadSecondaryIndexMetadata(CFMetaData parent) |
static CFMetaData |
CFMetaData.rename(CFMetaData cfm,
java.lang.String newName) |
static KSMetaData |
KSMetaData.testMetadata(java.lang.String name,
java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
java.util.Map<java.lang.String,java.lang.String> strategyOptions,
CFMetaData... cfDefs) |
static KSMetaData |
KSMetaData.testMetadataNotDurable(java.lang.String name,
java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
java.util.Map<java.lang.String,java.lang.String> strategyOptions,
CFMetaData... cfDefs) |
RowMutation |
CFMetaData.toSchemaUpdate(CFMetaData newState,
long modificationTimestamp,
boolean fromThrift)
Create schema mutations to update this metadata to provided new state.
|
void |
CFMetaData.validateCompatility(CFMetaData cfm) |
Modifier and Type | Method and Description |
---|---|
static KSMetaData |
KSMetaData.cloneWith(KSMetaData ksm,
java.lang.Iterable<CFMetaData> cfDefs) |
static KSMetaData |
KSMetaData.fromSchema(Row row,
java.lang.Iterable<CFMetaData> cfms)
Deserialize only Keyspace attributes without nested ColumnFamilies
|
static KSMetaData |
KSMetaData.newKeyspace(java.lang.String name,
java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
java.util.Map<java.lang.String,java.lang.String> options,
boolean durablesWrites,
java.lang.Iterable<CFMetaData> cfDefs) |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
DropIndexStatement.generateCFMetadataUpdate() |
CFMetaData |
AlterTableStatement.getCFMetaData(java.lang.String keyspace) |
CFMetaData |
CreateColumnFamilyStatement.getCFMetaData(java.lang.String keyspace,
java.util.List<java.nio.ByteBuffer> variables)
Returns a CFMetaData instance based on the parameters parsed from this
CREATE statement, or defaults where applicable. |
Modifier and Type | Method and Description |
---|---|
static void |
AlterTableStatement.applyPropertiesToCFMetadata(CFMetaData cfm,
CFPropDefs cfProps) |
void |
SelectStatement.extractKeyAliasFromColumns(CFMetaData cfm) |
void |
WhereClause.extractKeysFromColumns(CFMetaData cfm) |
RowMutation |
DeleteStatement.mutationForKey(java.nio.ByteBuffer key,
java.lang.String keyspace,
java.lang.Long timestamp,
ThriftClientState clientState,
java.util.List<java.nio.ByteBuffer> variables,
CFMetaData metadata) |
static void |
QueryProcessor.validateColumn(CFMetaData metadata,
java.nio.ByteBuffer name,
java.nio.ByteBuffer value) |
static void |
QueryProcessor.validateKeyAlias(CFMetaData cfm,
java.lang.String key) |
Modifier and Type | Field and Description |
---|---|
CFMetaData |
CFDefinition.cfm |
CFMetaData |
UpdateParameters.metadata |
Modifier and Type | Method and Description |
---|---|
boolean |
Operation.isStatic(CFMetaData cfm) |
protected ColumnNameBuilder |
Operation.maybeUpdatePrefix(CFMetaData cfm,
ColumnNameBuilder prefix) |
Constructor and Description |
---|
CFDefinition(CFMetaData cfm) |
UpdateParameters(CFMetaData metadata,
java.util.List<java.nio.ByteBuffer> variables,
long timestamp,
int ttl,
java.util.Map<java.nio.ByteBuffer,ColumnGroupMap> prefetchedLists) |
Constructor and Description |
---|
TokenFct(CFMetaData cfm) |
Modifier and Type | Field and Description |
---|---|
CFMetaData |
ModificationStatement.cfm |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
CreateTableStatement.getCFMetaData()
Returns a CFMetaData instance based on the parameters parsed from this
CREATE statement, or defaults where applicable. |
Modifier and Type | Method and Description |
---|---|
void |
CreateTableStatement.applyPropertiesTo(CFMetaData cfmd) |
void |
CFPropDefs.applyToCFMetadata(CFMetaData cfm) |
Constructor and Description |
---|
CQL3CasConditions(CFMetaData cfm,
long now) |
ModificationStatement(ModificationStatement.StatementType type,
CFMetaData cfm,
Attributes attrs) |
Modifier and Type | Field and Description |
---|---|
protected CFMetaData |
ColumnFamily.metadata |
CFMetaData |
ColumnFamilyStore.metadata |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
ColumnFamily.metadata() |
Modifier and Type | Method and Description |
---|---|
ColumnFamily |
RowMutation.addOrGet(CFMetaData cfm) |
ColumnFamily |
RowMutation.addOrGet(CFMetaData cfm,
ColumnFamily.Factory factory) |
static Column |
Column.create(java.nio.ByteBuffer name,
java.nio.ByteBuffer value,
long timestamp,
int ttl,
CFMetaData metadata) |
T |
ColumnFamily.Factory.create(CFMetaData metadata) |
abstract T |
ColumnFamily.Factory.create(CFMetaData metadata,
boolean insertReversed)
Returns a (initially empty) column map whose columns are sorted
according to the provided comparator.
|
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
IPartitioner partitioner,
CFMetaData metadata) |
static AbstractType<?> |
SuperColumns.getComparatorFor(CFMetaData metadata,
boolean subColumn) |
static AbstractType<?> |
SuperColumns.getComparatorFor(CFMetaData metadata,
java.nio.ByteBuffer superColumn) |
static PaxosState |
SystemKeyspace.loadPaxosState(java.nio.ByteBuffer key,
CFMetaData metadata) |
void |
ConsistencyLevel.validateCounterForWrite(CFMetaData metadata) |
void |
Column.validateFields(CFMetaData metadata) |
void |
CounterColumn.validateFields(CFMetaData metadata) |
void |
DeletedColumn.validateFields(CFMetaData metadata) |
void |
ExpiringColumn.validateFields(CFMetaData metadata) |
void |
OnDiskAtom.validateFields(CFMetaData metadata) |
void |
RangeTombstone.validateFields(CFMetaData metadata) |
protected void |
Column.validateName(CFMetaData metadata) |
Constructor and Description |
---|
AbstractThreadUnsafeSortedColumns(CFMetaData metadata) |
AbstractThreadUnsafeSortedColumns(CFMetaData metadata,
DeletionInfo deletionInfo) |
ColumnFamily(CFMetaData metadata) |
EmptyColumns(CFMetaData metadata,
DeletionInfo info) |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
CompactionInfo.getCFMetaData() |
Modifier and Type | Method and Description |
---|---|
void |
CompactionManager.interruptCompactionFor(java.lang.Iterable<CFMetaData> columnFamilies,
boolean interruptValidation)
Try to stop all of the compactions for given ColumnFamilies.
|
Constructor and Description |
---|
CompactionInfo(CFMetaData cfm,
OperationType tasktype,
long bytesComplete,
long totalBytes) |
CompactionInfo(CFMetaData cfm,
OperationType tasktype,
long completed,
long total,
java.lang.String unit) |
Modifier and Type | Method and Description |
---|---|
static AbstractType<?> |
SecondaryIndex.getIndexComparator(CFMetaData baseMetadata,
ColumnDefinition cdef)
Returns the index comparator for index backed by CFS, or null.
|
Modifier and Type | Method and Description |
---|---|
static CompositeType |
CompositesIndexOnClusteringKey.buildIndexComparator(CFMetaData baseMetadata,
ColumnDefinition columnDef) |
static CompositeType |
CompositesIndexOnPartitionKey.buildIndexComparator(CFMetaData baseMetadata,
ColumnDefinition columnDef) |
static CompositeType |
CompositesIndexOnRegular.buildIndexComparator(CFMetaData baseMetadata,
ColumnDefinition columnDef) |
static CompositeType |
CompositesIndex.getIndexComparator(CFMetaData baseMetadata,
ColumnDefinition cfDef) |
Modifier and Type | Field and Description |
---|---|
protected CFMetaData |
AbstractSSTableSimpleWriter.metadata |
CFMetaData |
SSTable.metadata |
Modifier and Type | Method and Description |
---|---|
abstract CFMetaData |
SSTableLoader.Client.getCFMetaData(java.lang.String keyspace,
java.lang.String cfName)
Validate that
keyspace is an existing keyspace and cfName one of its existing column family. |
Modifier and Type | Method and Description |
---|---|
long |
SSTableWriter.appendFromStream(DecoratedKey key,
CFMetaData metadata,
java.io.DataInput in,
Descriptor.Version version) |
static long |
SSTableReader.getApproximateKeyCount(java.lang.Iterable<SSTableReader> sstables,
CFMetaData metadata) |
static boolean |
SSTableReader.loadSummary(SSTableReader reader,
SegmentedFile.Builder ibuilder,
SegmentedFile.Builder dbuilder,
CFMetaData metadata) |
static SSTableReader |
SSTableReader.open(Descriptor desc,
CFMetaData metadata) |
static SSTableReader |
SSTableReader.open(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
static java.util.Collection<SSTableReader> |
SSTableReader.openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries,
CFMetaData metadata,
IPartitioner partitioner) |
static SSTableReader |
SSTableReader.openForBatch(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata) |
Constructor and Description |
---|
AbstractSSTableSimpleWriter(java.io.File directory,
CFMetaData metadata,
IPartitioner partitioner) |
SSTable(Descriptor descriptor,
CFMetaData metadata,
IPartitioner partitioner) |
SSTable(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
SSTableSimpleUnsortedWriter(java.io.File directory,
CFMetaData metadata,
IPartitioner partitioner,
long bufferSizeInMB) |
SSTableSimpleWriter(java.io.File directory,
CFMetaData metadata,
IPartitioner partitioner) |
SSTableWriter(java.lang.String filename,
long keyCount,
CFMetaData metadata,
IPartitioner<?> partitioner,
SSTableMetadata.Collector sstableMetadataCollector) |
Modifier and Type | Method and Description |
---|---|
static void |
MigrationManager.announceColumnFamilyUpdate(CFMetaData cfm,
boolean fromThrift) |
static void |
MigrationManager.announceNewColumnFamily(CFMetaData cfm) |
java.util.List<Pair<Range<Token>,java.lang.Long>> |
StorageService.getSplits(java.lang.String keyspaceName,
java.lang.String cfName,
Range<Token> range,
int keysPerSplit,
CFMetaData metadata) |
void |
MigrationManager.notifyCreateColumnFamily(CFMetaData cfm) |
void |
MigrationManager.notifyDropColumnFamily(CFMetaData cfm) |
void |
MigrationManager.notifyUpdateColumnFamily(CFMetaData cfm) |
Modifier and Type | Method and Description |
---|---|
static Commit |
Commit.emptyCommit(java.nio.ByteBuffer key,
CFMetaData metadata) |
static Commit |
Commit.newPrepare(java.nio.ByteBuffer key,
CFMetaData metadata,
java.util.UUID ballot) |
Constructor and Description |
---|
PaxosState(java.nio.ByteBuffer key,
CFMetaData metadata) |
PrepareCallback(java.nio.ByteBuffer key,
CFMetaData metadata,
int targets,
ConsistencyLevel consistency) |
Modifier and Type | Method and Description |
---|---|
static CFMetaData |
ThriftValidation.validateColumnFamily(java.lang.String keyspaceName,
java.lang.String cfName) |
static CFMetaData |
ThriftValidation.validateColumnFamily(java.lang.String keyspaceName,
java.lang.String cfName,
boolean isCommutativeOp) |
Modifier and Type | Method and Description |
---|---|
static IDiskAtomFilter |
ThriftValidation.asIFilter(SlicePredicate sp,
CFMetaData metadata,
java.nio.ByteBuffer superColumn) |
static void |
ThriftValidation.validateColumnData(CFMetaData metadata,
Column column,
boolean isSubColumn)
Validates the data part of the column (everything in the Column object but the name, which is assumed to be valid)
|
static void |
ThriftValidation.validateColumnNames(CFMetaData metadata,
ColumnParent column_parent,
java.lang.Iterable<java.nio.ByteBuffer> column_names) |
static void |
ThriftValidation.validateColumnOrSuperColumn(CFMetaData metadata,
ColumnOrSuperColumn cosc) |
static void |
ThriftValidation.validateColumnParent(CFMetaData metadata,
ColumnParent column_parent) |
static void |
ThriftValidation.validateColumnPath(CFMetaData metadata,
ColumnPath column_path)
validates all parts of the path to the column, including the column name
|
static void |
ThriftValidation.validateDeletion(CFMetaData metadata,
Deletion del) |
static boolean |
ThriftValidation.validateFilterClauses(CFMetaData metadata,
java.util.List<IndexExpression> index_clause) |
static void |
ThriftValidation.validateIndexClauses(CFMetaData metadata,
IndexClause index_clause) |
static void |
ThriftValidation.validateKey(CFMetaData metadata,
java.nio.ByteBuffer key) |
static void |
ThriftValidation.validateKeyRange(CFMetaData metadata,
java.nio.ByteBuffer superColumn,
KeyRange range) |
static void |
ThriftValidation.validateMutation(CFMetaData metadata,
Mutation mut) |
static void |
ThriftValidation.validatePredicate(CFMetaData metadata,
ColumnParent column_parent,
SlicePredicate predicate) |
static void |
ThriftValidation.validateRange(CFMetaData metadata,
ColumnParent column_parent,
SliceRange range) |
static void |
ThriftValidation.validateSlicePredicate(CFMetaData metadata,
java.nio.ByteBuffer scName,
SlicePredicate predicate) |
Modifier and Type | Method and Description |
---|---|
static java.nio.ByteBuffer |
Tracing.buildName(CFMetaData meta,
java.nio.ByteBuffer... args) |
Copyright © 2014 The Apache Software Foundation