Uses of Class
org.apache.cassandra.schema.TableMetadata
-
-
Uses of TableMetadata in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth with parameters of type TableMetadata Modifier and Type Method Description voidAuthSchemaChangeListener. onDropTable(TableMetadata table, boolean dropData) -
Uses of TableMetadata in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache with parameters of type TableMetadata Modifier and Type Method Description static CounterCacheKeyCounterCacheKey. create(TableMetadata tableMetadata, java.nio.ByteBuffer partitionKey, Clustering<?> clustering, ColumnMetadata c, CellPath path)static CounterCacheKeyCounterCacheKey. read(TableMetadata tableMetadata, DataInputPlus in)booleanCacheKey. sameTable(TableMetadata tableMetadata)Constructors in org.apache.cassandra.cache with parameters of type TableMetadata Constructor Description CacheKey(TableMetadata metadata)KeyCacheKey(TableMetadata tableMetadata, Descriptor desc, java.nio.ByteBuffer key)RowCacheKey(TableMetadata metadata, DecoratedKey key) -
Uses of TableMetadata in org.apache.cassandra.cql3
Fields in org.apache.cassandra.cql3 declared as TableMetadata Modifier and Type Field Description TableMetadataUpdateParameters. metadataMethods in org.apache.cassandra.cql3 with parameters of type TableMetadata Modifier and Type Method Description static UntypedResultSet.RowUntypedResultSet.Row. fromInternalRow(TableMetadata metadata, DecoratedKey key, Row row)short[]VariableSpecifications. getPartitionKeyBindVariableIndexes(TableMetadata metadata)Returns an array with the same length as the number of partition key columns for the table corresponding to table.intAttributes. getTimeToLive(QueryOptions options, TableMetadata metadata)protected RestrictionMultiColumnRelation. newContainsRestriction(TableMetadata table, VariableSpecifications boundNames, boolean isKey)protected abstract RestrictionRelation. newContainsRestriction(TableMetadata table, VariableSpecifications boundNames, boolean isKey)Creates a new Contains restriction instance.protected RestrictionSingleColumnRelation. newContainsRestriction(TableMetadata table, VariableSpecifications boundNames, boolean isKey)protected RestrictionTokenRelation. newContainsRestriction(TableMetadata table, VariableSpecifications boundNames, boolean isKey)protected RestrictionMultiColumnRelation. newEQRestriction(TableMetadata table, VariableSpecifications boundNames)protected abstract RestrictionRelation. newEQRestriction(TableMetadata table, VariableSpecifications boundNames)Creates a new EQ restriction instance.protected RestrictionSingleColumnRelation. newEQRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionTokenRelation. newEQRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionMultiColumnRelation. newINRestriction(TableMetadata table, VariableSpecifications boundNames)protected abstract RestrictionRelation. newINRestriction(TableMetadata table, VariableSpecifications boundNames)Creates a new IN restriction instance.protected RestrictionSingleColumnRelation. newINRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionTokenRelation. newINRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionMultiColumnRelation. newIsNotRestriction(TableMetadata table, VariableSpecifications boundNames)protected abstract RestrictionRelation. newIsNotRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionSingleColumnRelation. newIsNotRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionTokenRelation. newIsNotRestriction(TableMetadata table, VariableSpecifications boundNames)protected RestrictionMultiColumnRelation. newLikeRestriction(TableMetadata table, VariableSpecifications boundNames, Operator operator)protected abstract RestrictionRelation. newLikeRestriction(TableMetadata table, VariableSpecifications boundNames, Operator operator)protected RestrictionSingleColumnRelation. newLikeRestriction(TableMetadata table, VariableSpecifications boundNames, Operator operator)protected RestrictionTokenRelation. newLikeRestriction(TableMetadata table, VariableSpecifications boundNames, Operator operator)protected RestrictionMultiColumnRelation. newSliceRestriction(TableMetadata table, VariableSpecifications boundNames, Bound bound, boolean inclusive)protected abstract RestrictionRelation. newSliceRestriction(TableMetadata table, VariableSpecifications boundNames, Bound bound, boolean inclusive)Creates a new Slice restriction instance.protected RestrictionSingleColumnRelation. newSliceRestriction(TableMetadata table, VariableSpecifications boundNames, Bound bound, boolean inclusive)protected RestrictionTokenRelation. newSliceRestriction(TableMetadata table, VariableSpecifications boundNames, Bound bound, boolean inclusive)OperationOperation.Addition. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.ColumnDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)OperationOperation.ElementDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)OperationOperation.FieldDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)OperationOperation.Prepend. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.RawDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)This method validates the operation (i.e.OperationOperation.RawUpdate. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)This method validates the operation (i.e.OperationOperation.SetElement. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.SetField. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.SetValue. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.Substraction. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)Json.PreparedJson.Literal. prepareAndCollectMarkers(TableMetadata metadata, java.util.Collection<ColumnMetadata> receivers, VariableSpecifications boundNames)Json.PreparedJson.Marker. prepareAndCollectMarkers(TableMetadata metadata, java.util.Collection<ColumnMetadata> receivers, VariableSpecifications boundNames)Json.PreparedJson.Raw. prepareAndCollectMarkers(TableMetadata metadata, java.util.Collection<ColumnMetadata> receivers, VariableSpecifications boundNames)protected java.util.List<ColumnMetadata>MultiColumnRelation. receivers(TableMetadata table)RestrictionRelation. toRestriction(TableMetadata table, VariableSpecifications boundNames)Converts thisRelationinto aRestriction.static voidValidation. validateKey(TableMetadata metadata, java.nio.ByteBuffer key)Validates a (full serialized) partition key.Constructors in org.apache.cassandra.cql3 with parameters of type TableMetadata Constructor Description UpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, int nowInSec, int ttl, java.util.Map<DecoratedKey,Partition> prefetchedRows) -
Uses of TableMetadata in org.apache.cassandra.cql3.conditions
Methods in org.apache.cassandra.cql3.conditions with parameters of type TableMetadata Modifier and Type Method Description ColumnConditionColumnCondition.Raw. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata cfm) -
Uses of TableMetadata in org.apache.cassandra.cql3.functions
Constructors in org.apache.cassandra.cql3.functions with parameters of type TableMetadata Constructor Description TokenFct(TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.cql3.restrictions
Fields in org.apache.cassandra.cql3.restrictions declared as TableMetadata Modifier and Type Field Description protected TableMetadataTokenRestriction. metadataTableMetadataStatementRestrictions. tableThe Column Family meta dataMethods in org.apache.cassandra.cql3.restrictions with parameters of type TableMetadata Modifier and Type Method Description voidCustomIndexExpression. addToRowFilter(RowFilter filter, TableMetadata table, QueryOptions options)static StatementRestrictionsStatementRestrictions. empty(StatementType type, TableMetadata table)Creates a new emptyStatementRestrictions.booleanTokenRestriction. hasUnrestrictedPartitionKeyComponents(TableMetadata table)booleanTokenRestriction. needFiltering(TableMetadata table)voidCustomIndexExpression. prepareValue(TableMetadata table, AbstractType<?> expressionType, VariableSpecifications boundNames)Constructors in org.apache.cassandra.cql3.restrictions with parameters of type TableMetadata Constructor Description EQRestriction(TableMetadata table, java.util.List<ColumnMetadata> columnDefs, Term value)SliceRestriction(TableMetadata table, java.util.List<ColumnMetadata> columnDefs, Bound bound, boolean inclusive, Term term)StatementRestrictions(StatementType type, TableMetadata table, WhereClause whereClause, VariableSpecifications boundNames, boolean selectsOnlyStaticColumns, boolean allowFiltering, boolean forView)StatementRestrictions(StatementType type, TableMetadata table, WhereClause whereClause, VariableSpecifications boundNames, boolean selectsOnlyStaticColumns, boolean allowUseOfSecondaryIndices, boolean allowFiltering, boolean forView)TokenRestriction(TableMetadata metadata, java.util.List<ColumnMetadata> columnDefs)Creates a newTokenRestrictionthat apply to the specified columns. -
Uses of TableMetadata in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type TableMetadata Modifier and Type Method Description protected abstract SelectorSelector.SelectorDeserializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)SelectorSelector.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)static SelectionSelection. forColumns(TableMetadata table, java.util.List<ColumnMetadata> columns, boolean returnStaticContentOnPartitionWithNoRows)static SelectionSelection. fromSelectors(TableMetadata table, java.util.List<Selectable> selectables, VariableSpecifications boundNames, java.util.Set<ColumnMetadata> orderingColumns, java.util.Set<ColumnMetadata> nonPKRestrictedColumns, boolean hasGroupBy, boolean isJson, boolean returnStaticContentOnPartitionWithNoRows)ColumnSpecificationSelector.Factory. getColumnSpecification(TableMetadata table)Returns the column specification corresponding to the output value of the selector instances created by this factory.Selector.FactorySelectable.BetweenParenthesesOrWithTuple. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithCast. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithElementSelection. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithFieldSelection. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithFunction. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithList. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithMapOrUdt. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithSet. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithSliceSelection. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithTerm. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithToJSonFunction. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WithTypeHint. newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)Selector.FactorySelectable.WritetimeOrTTL. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)SelectableSelectable.BetweenParenthesesOrWithTuple.Raw. prepare(TableMetadata cfm)SelectableSelectable.Raw. prepare(TableMetadata table)ColumnMetadataSelectable.RawIdentifier. prepare(TableMetadata cfm)Selectable.WithCastSelectable.WithCast.Raw. prepare(TableMetadata table)Selectable.WithElementSelectionSelectable.WithElementSelection.Raw. prepare(TableMetadata cfm)Selectable.WithFieldSelectionSelectable.WithFieldSelection.Raw. prepare(TableMetadata table)SelectableSelectable.WithFunction.Raw. prepare(TableMetadata table)SelectableSelectable.WithList.Raw. prepare(TableMetadata cfm)SelectableSelectable.WithMapOrUdt.Raw. prepare(TableMetadata cfm)SelectableSelectable.WithSet.Raw. prepare(TableMetadata cfm)Selectable.WithSliceSelectionSelectable.WithSliceSelection.Raw. prepare(TableMetadata cfm)SelectableSelectable.WithTerm.Raw. prepare(TableMetadata table)SelectableSelectable.WithTypeHint.Raw. prepare(TableMetadata cfm)Selectable.WritetimeOrTTLSelectable.WritetimeOrTTL.Raw. prepare(TableMetadata table)protected AbstractType<?>Selector.SelectorDeserializer. readType(TableMetadata metadata, DataInputPlus in)static java.util.List<Selectable>RawSelector. toSelectables(java.util.List<RawSelector> raws, TableMetadata table)Converts the specified list ofRawSelectors into a list ofSelectables.static SelectionSelection. wildcard(TableMetadata table, boolean isJson, boolean returnStaticContentOnPartitionWithNoRows)static SelectionSelection. wildcardWithGroupBy(TableMetadata table, VariableSpecifications boundNames, boolean isJson, boolean returnStaticContentOnPartitionWithNoRows)Constructors in org.apache.cassandra.cql3.selection with parameters of type TableMetadata Constructor Description Selection(TableMetadata table, java.util.List<ColumnMetadata> selectedColumns, java.util.Set<ColumnMetadata> orderingColumns, SelectionColumnMapping columnMapping, org.apache.cassandra.cql3.selection.ColumnFilterFactory columnFilterFactory, boolean isJson)WithMapOrUdt(TableMetadata cfm, java.util.List<Pair<Selectable.Raw,Selectable.Raw>> raws) -
Uses of TableMetadata in org.apache.cassandra.cql3.statements
Fields in org.apache.cassandra.cql3.statements declared as TableMetadata Modifier and Type Field Description TableMetadataCQL3CasRequest. metadataTableMetadataModificationStatement. metadataTableMetadataSelectStatement. tableMethods in org.apache.cassandra.cql3.statements that return TableMetadata Modifier and Type Method Description TableMetadataModificationStatement. metadata()Methods in org.apache.cassandra.cql3.statements with parameters of type TableMetadata Modifier and Type Method Description static java.nio.ByteBuffer[]SelectStatement. getComponents(TableMetadata metadata, DecoratedKey dk)PartitionUpdate.BuilderUpdatesCollector. getPartitionUpdateBuilder(TableMetadata metadata, DecoratedKey dk, ConsistencyLevel consistency)protected StatementRestrictionsModificationStatement.Parsed. newRestrictions(TableMetadata metadata, VariableSpecifications boundNames, Operations operations, WhereClause where, Conditions conditions)Creates the restrictions.protected ModificationStatementDeleteStatement.Parsed. prepareInternal(TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs)protected abstract ModificationStatementModificationStatement.Parsed. prepareInternal(TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs)protected ModificationStatementUpdateStatement.ParsedInsert. prepareInternal(TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs)protected ModificationStatementUpdateStatement.ParsedInsertJson. prepareInternal(TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs)protected ModificationStatementUpdateStatement.ParsedUpdate. prepareInternal(TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs)static SlicesModificationStatement. toSlices(TableMetadata metadata, java.util.SortedSet<ClusteringBound<?>> startBounds, java.util.SortedSet<ClusteringBound<?>> endBounds)Constructors in org.apache.cassandra.cql3.statements with parameters of type TableMetadata Constructor Description CQL3CasRequest(TableMetadata metadata, DecoratedKey key, RegularAndStaticColumns conditionColumns, boolean updatesRegularRows, boolean updatesStaticRow)ModificationStatement(StatementType type, VariableSpecifications bindVariables, TableMetadata metadata, Operations operations, StatementRestrictions restrictions, Conditions conditions, Attributes attrs)SelectStatement(TableMetadata table, VariableSpecifications bindVariables, SelectStatement.Parameters parameters, Selection selection, StatementRestrictions restrictions, boolean isReversed, AggregationSpecification.Factory aggregationSpecFactory, java.util.Comparator<java.util.List<java.nio.ByteBuffer>> orderingComparator, Term limit, Term perPartitionLimit) -
Uses of TableMetadata in org.apache.cassandra.cql3.statements.schema
Methods in org.apache.cassandra.cql3.statements.schema with parameters of type TableMetadata Modifier and Type Method Description KeyspaceMetadataAlterTableStatement.AlterColumn. apply(KeyspaceMetadata keyspace, TableMetadata table)IndexTargetIndexTarget.Raw. prepare(TableMetadata table) -
Uses of TableMetadata in org.apache.cassandra.db
Fields in org.apache.cassandra.db declared as TableMetadata Modifier and Type Field Description static TableMetadataSystemKeyspace. Batchesprotected TableMetadataUnfilteredDeserializer. metadataMethods in org.apache.cassandra.db that return TableMetadata Modifier and Type Method Description TableMetadataColumnFamilyStore. metadata()TableMetadataReadExecutionController. metadata()TableMetadataReadQuery. metadata()The metadata for the table this is a query on.TableMetadataSimpleBuilders.PartitionUpdateBuilder. metadata()TableMetadataSinglePartitionReadQuery.Group. metadata()Methods in org.apache.cassandra.db with parameters of type TableMetadata Modifier and Type Method Description static PartitionRangeReadCommandPartitionRangeReadCommand. allDataRead(TableMetadata metadata, int nowInSec)Creates a new read command that query all the data in the table.static PartitionRangeReadCommandPartitionRangeReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)static ReadQueryPartitionRangeReadQuery. create(TableMetadata table, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, java.nio.ByteBuffer key, Slices slices)Creates a new single partition slice command for the provided slices.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, java.util.NavigableSet<Clustering<?>> names)Creates a new single partition name command for the provided rows.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, Clustering<?> name)Creates a new single partition name command for the provided row.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter)Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, Slice slice)Creates a new single partition slice command for the provided single slice.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, Slices slices)Creates a new single partition slice command for the provided slices.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata indexMetadata)Creates a new read command on a single partition.static SinglePartitionReadCommand.GroupSinglePartitionReadCommand.Group. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)static SinglePartitionReadQuerySinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter)Creates a new read query on a single partition.static SinglePartitionReadQuerySinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)Creates a new read query on a single partition.static UnfilteredDeserializerUnfilteredDeserializer. create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper)static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery>SinglePartitionReadQuery. createGroup(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)ColumnsColumns.Serializer. deserialize(DataInputPlus in, TableMetadata metadata)DataRangeDataRange.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)abstract ReadCommandReadCommand.SelectionDeserializer. deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, IndexMetadata index)SlicesSlices.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)SerializationHeaderSerializationHeader.Serializer. deserializeForMessaging(DataInputPlus in, TableMetadata metadata, ColumnFilter selection, boolean hasStatic)static ReadQueryReadQuery. empty(TableMetadata metadata)static SinglePartitionReadCommandSinglePartitionReadCommand. fullPartitionRead(TableMetadata metadata, int nowInSec, java.nio.ByteBuffer key)Creates a new read command that queries a single partition in its entirety.static SinglePartitionReadCommandSinglePartitionReadCommand. fullPartitionRead(TableMetadata metadata, int nowInSec, DecoratedKey key)Creates a new read command that queries a single partition in its entirety.Directories.DataDirectory[]Directories.DataDirectories. getDataDirectoriesFor(TableMetadata table)Returns the data directories for the specified table.static ColumnFamilyStoreColumnFamilyStore. getIfExists(TableMetadata table)Returns a ColumnFamilyStore by metadata if it exists, null otherwise Differently from others, this method does not throw exception if the table does not exist.static java.util.stream.Stream<java.lang.String>SchemaCQLHelper. getIndexesAsCQL(TableMetadata metadata, boolean ifNotExists)Build a CQL String representation of Indexes on columns in the given Column FamilyPartitionUpdateMutation. getPartitionUpdate(TableMetadata table)static java.lang.StringSchemaCQLHelper. getTableMetadataAsCQL(TableMetadata metadata, KeyspaceMetadata keyspaceMetadata)Build a CQL String representation of Column Family Metadata.static TopPartitionTracker.StoredTopPartitionsSystemKeyspace. getTopPartitions(TableMetadata metadata, java.lang.String topType)static java.util.stream.Stream<java.lang.String>SchemaCQLHelper. getUserTypesAsCQL(TableMetadata metadata, Types types, boolean ifNotExists)Build a CQL String representation of User Types used in the given table.static voidUnfilteredValidation. handleInvalid(TableMetadata metadata, DecoratedKey key, SSTableReader sstable, java.lang.String invalidContent)booleanDataRange. isUnrestricted(TableMetadata metadata)Whether thisDataRangequeries everything (has no restriction neither on the partition queried, nor within the queried partition).booleanDataRange.Paging. isUnrestricted(TableMetadata metadata)static intSystemKeyspace. legacyPaxosTtlSec(TableMetadata metadata)static PaxosState.SnapshotSystemKeyspace. loadPaxosState(DecoratedKey partitionKey, TableMetadata metadata, int nowInSec)Load the current paxos state for the table and key NOTE: nowInSec is typically provided as zero, and should not be assumed to be definitive, as the cache may apply different nowInSec filtersstatic SerializationHeaderSerializationHeader. make(TableMetadata metadata, java.util.Collection<SSTableReader> sstables)static SerializationHeaderSerializationHeader. makeWithoutStats(TableMetadata metadata)static voidExpirationDateOverflowHandling. maybeApplyExpirationDateOverflowPolicy(TableMetadata metadata, int ttl, boolean isDefaultTTL)static voidUnfilteredValidation. maybeValidateUnfiltered(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey key, SSTableReader sstable)voidSizeEstimatesRecorder. onDropTable(TableMetadata table, boolean dropData)static ColumnFamilyStoreKeyspace. openAndGetStore(TableMetadata table)static ColumnFamilyStoreKeyspace. openAndGetStoreIfExists(TableMetadata table)static java.util.stream.Stream<java.lang.String>SchemaCQLHelper. reCreateStatementsForSchemaCql(TableMetadata metadata, KeyspaceMetadata keyspaceMetadata)Generates the DDL statement for aschema.cqlsnapshot file.static RowIteratorEmptyIterators. row(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder)static voidSystemKeyspace. savePaxosReadPromise(DecoratedKey key, TableMetadata metadata, Ballot ballot)static voidSystemKeyspace. savePaxosWritePromise(DecoratedKey key, TableMetadata metadata, Ballot ballot)static voidSystemKeyspace. saveTopPartitions(TableMetadata metadata, java.lang.String topType, java.util.Collection<TopPartitionTracker.TopPartition> topPartitions, long lastUpdate)static voidColumnFamilyStore. scrubDataDirectories(TableMetadata metadata)Removes unnecessary files from the cf directory at startup: these include temp files, orphans, zero-length files and compacted sstables.voidDataRange.Serializer. serialize(DataRange range, DataOutputPlus out, int version, TableMetadata metadata)longDataRange.Serializer. serializedSize(DataRange range, int version, TableMetadata metadata)default java.lang.StringClustering. toCQLString(TableMetadata metadata)java.lang.StringDataRange. toCQLString(TableMetadata metadata, RowFilter rowFilter)java.lang.StringDecoratedKey. toCQLString(TableMetadata metadata)Returns a CQL representation of this key.abstract java.lang.StringSlices. toCQLString(TableMetadata metadata, RowFilter rowFilter)SerializationHeaderSerializationHeader.Component. toHeader(TableMetadata metadata)default java.lang.StringClustering. toString(TableMetadata metadata)default java.lang.StringClusteringBoundOrBoundary. toString(TableMetadata metadata)java.lang.StringClusteringPrefix. toString(TableMetadata metadata)Generates a proper string representation of the prefix.java.lang.StringDataRange.Paging. toString(TableMetadata metadata)java.lang.StringDataRange. toString(TableMetadata metadata)static UnfilteredPartitionIteratorEmptyIterators. unfilteredPartition(TableMetadata metadata)static UnfilteredRowIteratorEmptyIterators. unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder)static UnfilteredRowIteratorEmptyIterators. unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder, Row staticRow, DeletionTime partitionDeletion)PartitionUpdate.SimpleBuilderMutation.SimpleBuilder. update(TableMetadata metadata)Adds an update for table identified by the provided metadata and return a builder for that partition.PartitionUpdate.SimpleBuilderSimpleBuilders.MutationBuilder. update(TableMetadata metadata)voidConsistencyLevel. validateCounterForWrite(TableMetadata metadata)Constructors in org.apache.cassandra.db with parameters of type TableMetadata Constructor Description Directories(TableMetadata metadata)Directories(TableMetadata metadata, java.util.Collection<Directories.DataDirectory> paths)Directories(TableMetadata metadata, Directories.DataDirectory[] paths)Create Directories of given ColumnFamily.PartitionRangeReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange, IndexMetadata index, boolean trackWarnings)PartitionUpdateBuilder(TableMetadata metadata, java.lang.Object... partitionKeyValues)ReadCommand(ReadCommand.Kind kind, boolean isDigestQuery, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, IndexMetadata index, boolean trackWarnings)RowBuilder(TableMetadata metadata, java.lang.Object... clusteringColumns)SerializationHeader(boolean isForSSTable, TableMetadata metadata, RegularAndStaticColumns columns, EncodingStats stats)SinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata index, boolean trackWarnings)VirtualTableSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata index, boolean trackWarnings) -
Uses of TableMetadata in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation with parameters of type TableMetadata Modifier and Type Method Description AggregationSpecificationAggregationSpecification.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.db.columniterator
Fields in org.apache.cassandra.db.columniterator declared as TableMetadata Modifier and Type Field Description protected TableMetadataAbstractSSTableIterator. metadataMethods in org.apache.cassandra.db.columniterator that return TableMetadata Modifier and Type Method Description TableMetadataAbstractSSTableIterator. metadata() -
Uses of TableMetadata in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction that return TableMetadata Modifier and Type Method Description TableMetadataCompactionInfo. getTableMetadata()TableMetadataCompactionIterator. metadata()Methods in org.apache.cassandra.db.compaction with parameters of type TableMetadata Modifier and Type Method Description voidCompactionStrategyManager. maybeReload(TableMetadata metadata)static CompactionInfoCompactionInfo. withoutSSTables(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId)Special compaction info where we always need to cancel the compaction - for example ViewBuilderTask and AutoSavingCache where we don't know the sstables at constructionMethod parameters in org.apache.cassandra.db.compaction with type arguments of type TableMetadata Modifier and Type Method Description voidCompactionManager. interruptCompactionFor(java.lang.Iterable<TableMetadata> columnFamilies, java.util.function.Predicate<SSTableReader> sstablePredicate, boolean interruptValidation)Try to stop all of the compactions for given ColumnFamilies.Constructors in org.apache.cassandra.db.compaction with parameters of type TableMetadata Constructor Description CompactionInfo(TableMetadata metadata, OperationType tasktype, long bytesComplete, long totalBytes, TimeUUID compactionId, java.util.Collection<SSTableReader> sstables) -
Uses of TableMetadata in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter with parameters of type TableMetadata Modifier and Type Method Description voidRowFilter. addCustomIndexExpression(TableMetadata metadata, IndexMetadata targetIndex, java.nio.ByteBuffer value)static ColumnFilterColumnFilter. all(TableMetadata metadata)A filter that includes all columns for the provided table.static ColumnFilter.BuilderColumnFilter. allRegularColumnsBuilder(TableMetadata metadata, boolean returnStaticContentOnPartitionWithNoRows)Returns aColumnFilterbuilder that fetches all regular columns or all columns (and queries the columns added to the builder, or everything if no column is added).protected voidAbstractClusteringIndexFilter. appendOrderByToCQLString(TableMetadata metadata, java.lang.StringBuilder sb)ClusteringIndexFilterClusteringIndexFilter.InternalDeserializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, boolean reversed)ClusteringIndexFilterClusteringIndexFilter.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)ColumnFilterColumnFilter.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)ColumnSubselectionColumnSubselection.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)DataLimitsDataLimits.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)RowFilterRowFilter.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)protected abstract RowFilter.UserExpressionRowFilter.UserExpression.Deserializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)PartitionIteratorRowFilter. filter(PartitionIterator iter, TableMetadata metadata, int nowInSec)Filters the provided iterator so that only the row satisfying the expression of this filter are included in the resulting iterator.protected abstract Transformation<BaseRowIterator<?>>RowFilter. filter(TableMetadata metadata, int nowInSec)SlicesClusteringIndexFilter. getSlices(TableMetadata metadata)SlicesClusteringIndexNamesFilter. getSlices(TableMetadata metadata)SlicesClusteringIndexSliceFilter. getSlices(TableMetadata metadata)protected java.nio.ByteBufferRowFilter.Expression. getValue(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)booleanRowFilter.CustomExpression. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)abstract booleanRowFilter.Expression. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)Returns whether the provided row satisfied this expression or not.booleanRowFilter. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)Whether the provided row in the provided partition satisfies this filter.booleanRowFilter.SimpleExpression. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)static ColumnFilter.SelectionColumnFilterColumnFilter.SelectionColumnFilter. newInstance(org.apache.cassandra.db.filter.ColumnFilter.FetchingStrategy fetchingStrategy, TableMetadata metadata, RegularAndStaticColumns queried, com.google.common.collect.SortedSetMultimap<ColumnIdentifier,ColumnSubselection> subSelections)static ColumnFilterColumnFilter. selection(TableMetadata metadata, RegularAndStaticColumns queried, boolean returnStaticContentOnPartitionWithNoRows)A filter that fetches all columns for the provided table, but returns only the queried ones.java.lang.StringClusteringIndexFilter. toCQLString(TableMetadata metadata, RowFilter rowFilter)java.lang.StringClusteringIndexNamesFilter. toCQLString(TableMetadata metadata, RowFilter rowFilter)java.lang.StringClusteringIndexSliceFilter. toCQLString(TableMetadata metadata, RowFilter rowFilter)java.lang.StringClusteringIndexFilter. toString(TableMetadata metadata)java.lang.StringClusteringIndexNamesFilter. toString(TableMetadata metadata)java.lang.StringClusteringIndexSliceFilter. toString(TableMetadata metadata)Constructors in org.apache.cassandra.db.filter with parameters of type TableMetadata Constructor Description CustomExpression(TableMetadata table, IndexMetadata targetIndex, java.nio.ByteBuffer value)TombstoneOverwhelmingException(int numTombstones, java.lang.String query, TableMetadata metadata, DecoratedKey lastPartitionKey, ClusteringPrefix<?> lastClustering) -
Uses of TableMetadata in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle with parameters of type TableMetadata Modifier and Type Method Description static booleanLifecycleTransaction. removeUnfinishedLeftovers(TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable that return TableMetadata Modifier and Type Method Description TableMetadataAbstractMemtable. metadata()default TableMetadataMemtable.FlushablePartitionSet. metadata()TableMetadataMemtable. metadata()The table's definition metadata.TableMetadataShardedSkipListMemtable.MemtableUnfilteredPartitionIterator. metadata()Constructors in org.apache.cassandra.db.memtable with parameters of type TableMetadata Constructor Description MemtableUnfilteredPartitionIterator(TableMetadata metadata, java.util.Iterator<AtomicBTreePartition> iterator, ColumnFilter columnFilter, DataRange dataRange) -
Uses of TableMetadata in org.apache.cassandra.db.partitions
Fields in org.apache.cassandra.db.partitions declared as TableMetadata Modifier and Type Field Description protected TableMetadataImmutableBTreePartition. metadataMethods in org.apache.cassandra.db.partitions that return TableMetadata Modifier and Type Method Description abstract TableMetadataAbstractBTreePartition. metadata()TableMetadataAtomicBTreePartition. metadata()TableMetadataImmutableBTreePartition. metadata()TableMetadataPartition. metadata()TableMetadataPartitionUpdate.Builder. metadata()TableMetadataPartitionUpdate. metadata()TableMetadataPartitionUpdate.SimpleBuilder. metadata()The metadata of the table this is a builder on.TableMetadataSingletonUnfilteredPartitionIterator. metadata()TableMetadataUnfilteredPartitionIterator. metadata()Methods in org.apache.cassandra.db.partitions with parameters of type TableMetadata Modifier and Type Method Description UnfilteredPartitionIteratorUnfilteredPartitionIterators.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)static PartitionUpdatePartitionUpdate. emptyUpdate(TableMetadata metadata, DecoratedKey key)Creates a empty immutable partition update.static PartitionUpdatePartitionUpdate. fullPartitionDelete(TableMetadata metadata, java.nio.ByteBuffer key, long timestamp, int nowInSec)Creates a partition update that entirely deletes a given partition.static PartitionUpdatePartitionUpdate. fullPartitionDelete(TableMetadata metadata, DecoratedKey key, long timestamp, int nowInSec)Creates an immutable partition update that entirely deletes a given partition.static PartitionUpdate.SimpleBuilderPartitionUpdate. simpleBuilder(TableMetadata metadata, java.lang.Object... partitionKeyValues)Creates a new simple partition update builder.static PartitionUpdatePartitionUpdate. singleRowUpdate(TableMetadata metadata, java.nio.ByteBuffer key, Row row)Creates an immutable partition update that contains a single row update.static PartitionUpdatePartitionUpdate. singleRowUpdate(TableMetadata metadata, DecoratedKey key, Row row)Creates an immutable partition update that contains a single row update.static PartitionUpdatePartitionUpdate. singleRowUpdate(TableMetadata metadata, DecoratedKey key, Row row, Row staticRow)Creates an immutable partition update that contains a single row update.static PartitionUpdatePartitionUpdate. unsafeConstruct(TableMetadata metadata, DecoratedKey key, AbstractBTreePartition.Holder holder, MutableDeletionInfo deletionInfo, boolean canHaveShadowedData)Constructors in org.apache.cassandra.db.partitions with parameters of type TableMetadata Constructor Description Builder(TableMetadata metadata, java.nio.ByteBuffer key, RegularAndStaticColumns columns, int initialRowCapacity)Builder(TableMetadata metadata, DecoratedKey key, RegularAndStaticColumns columnDefinitions, int size)Builder(TableMetadata metadata, DecoratedKey key, RegularAndStaticColumns columns, int initialRowCapacity, boolean canHaveShadowedData)ImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, AbstractBTreePartition.Holder holder)ImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, RegularAndStaticColumns columns, Row staticRow, java.lang.Object[] tree, DeletionInfo deletionInfo, EncodingStats stats) -
Uses of TableMetadata in org.apache.cassandra.db.repair
Methods in org.apache.cassandra.db.repair that return TableMetadata Modifier and Type Method Description TableMetadataCassandraValidationIterator. metadata() -
Uses of TableMetadata in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as TableMetadata Modifier and Type Field Description protected TableMetadataAbstractUnfilteredRowIterator. metadataMethods in org.apache.cassandra.db.rows that return TableMetadata Modifier and Type Method Description TableMetadataAbstractUnfilteredRowIterator. metadata()TableMetadataBaseRowIterator. metadata()The metadata for the table this iterator on.TableMetadataLazilyInitializedUnfilteredRowIterator. metadata()TableMetadataUnfilteredRowIteratorWithLowerBound. metadata()TableMetadataWrappingUnfilteredRowIterator. metadata()Methods in org.apache.cassandra.db.rows with parameters of type TableMetadata Modifier and Type Method Description java.lang.Iterable<Cell<?>>BTreeRow. cellsInLegacyOrder(TableMetadata metadata, boolean reversed)java.lang.Iterable<Cell<?>>Row. cellsInLegacyOrder(TableMetadata metadata, boolean reversed)An iterable over the cells of this row that return cells in "legacy order".UnfilteredRowIteratorUnfilteredRowIteratorSerializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)UnfilteredRowIteratorUnfilteredRowIteratorSerializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, DeserializationHelper.Flag flag, UnfilteredRowIteratorSerializer.Header header)UnfilteredRowIteratorSerializer.HeaderUnfilteredRowIteratorSerializer. deserializeHeader(TableMetadata metadata, ColumnFilter selection, DataInputPlus in, int version, DeserializationHelper.Flag flag)RowBTreeRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)RowBTreeRow. filter(ColumnFilter filter, TableMetadata metadata)RowRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)Returns a copy of this row that: 1) only includes the data for the column included byfilter.RowRow. filter(ColumnFilter filter, TableMetadata metadata)Returns a copy of this row that: 1) only includes the data for the column included byfilter.static UnfilteredRowIteratorUnfilteredRowIterators. noRowsIterator(TableMetadata metadata, DecoratedKey partitionKey, Row staticRow, DeletionTime partitionDeletion, boolean isReverseOrder)Returns an empty unfiltered iterator for a given partition.static Row.SimpleBuilderRows. simpleBuilder(TableMetadata metadata, java.lang.Object... clusteringValues)Creates a new simple row builder.static UnfilteredRowIteratorUnfilteredRowIterators. singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats)java.lang.StringAbstractRangeTombstoneMarker. toString(TableMetadata metadata, boolean fullDetails)java.lang.StringAbstractRangeTombstoneMarker. toString(TableMetadata metadata, boolean includeClusteringKeys, boolean fullDetails)java.lang.StringAbstractRow. toString(TableMetadata metadata)java.lang.StringAbstractRow. toString(TableMetadata metadata, boolean fullDetails)java.lang.StringAbstractRow. toString(TableMetadata metadata, boolean includeClusterKeys, boolean fullDetails)java.lang.StringRangeTombstoneBoundaryMarker. toString(TableMetadata metadata)java.lang.StringRangeTombstoneBoundMarker. toString(TableMetadata metadata)java.lang.StringRow. toString(TableMetadata metadata, boolean fullDetails)java.lang.StringUnfiltered. toString(TableMetadata metadata)java.lang.StringUnfiltered. toString(TableMetadata metadata, boolean fullDetails)java.lang.StringUnfiltered. toString(TableMetadata metadata, boolean includeClusterKeys, boolean fullDetails)voidAbstractRangeTombstoneMarker. validateData(TableMetadata metadata)voidAbstractRow. validateData(TableMetadata metadata)voidUnfiltered. validateData(TableMetadata metadata)Validate the data of this atom.Constructors in org.apache.cassandra.db.rows with parameters of type TableMetadata Constructor Description AbstractUnfilteredRowIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats stats)DeserializationHelper(TableMetadata metadata, int version, DeserializationHelper.Flag flag)DeserializationHelper(TableMetadata metadata, int version, DeserializationHelper.Flag flag, ColumnFilter columnsToFetch)RowAndDeletionMergeIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, ColumnFilter selection, Row staticRow, boolean isReversed, EncodingStats stats, java.util.Iterator<Row> rows, java.util.Iterator<RangeTombstone> ranges, boolean removeShadowedData) -
Uses of TableMetadata in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming that return TableMetadata Modifier and Type Method Description TableMetadataCassandraStreamReader.StreamDeserializer. metadata()Methods in org.apache.cassandra.db.streaming with parameters of type TableMetadata Modifier and Type Method Description protected CassandraStreamReader.StreamDeserializerCassandraStreamReader. getDeserializer(TableMetadata metadata, TrackedDataInputPlus in, Version inputVersion, StreamSession session, SSTableMultiWriter writer)protected SerializationHeaderCassandraStreamReader. getHeader(TableMetadata metadata)Constructors in org.apache.cassandra.db.streaming with parameters of type TableMetadata Constructor Description StreamDeserializer(TableMetadata metadata, DataInputPlus in, Version version, SerializationHeader header, StreamSession session, SSTableMultiWriter writer) -
Uses of TableMetadata in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return TableMetadata Modifier and Type Method Description TableMetadataBaseRows. metadata() -
Uses of TableMetadata in org.apache.cassandra.db.virtual
Fields in org.apache.cassandra.db.virtual declared as TableMetadata Modifier and Type Field Description protected TableMetadataAbstractVirtualTable. metadataMethods in org.apache.cassandra.db.virtual that return TableMetadata Modifier and Type Method Description TableMetadataVirtualKeyspaceRegistry. getTableMetadataNullable(TableId id)TableMetadataAbstractVirtualTable. metadata()TableMetadataVirtualTable. metadata()Returns the view metadata.Methods in org.apache.cassandra.db.virtual with parameters of type TableMetadata Modifier and Type Method Description static AbstractMutableVirtualTable.ColumnValuesAbstractMutableVirtualTable.ColumnValues. from(TableMetadata metadata, ClusteringPrefix<?> prefix)Returns the set of column values corresponding to the specified clustering prefix.static AbstractMutableVirtualTable.ColumnValuesAbstractMutableVirtualTable.ColumnValues. from(TableMetadata metadata, DecoratedKey partitionKey)Returns the set of column values corresponding to the specified partition key.UnfilteredRowIteratorAbstractVirtualTable.Partition. toRowIterator(TableMetadata metadata, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter, long now)Constructors in org.apache.cassandra.db.virtual with parameters of type TableMetadata Constructor Description AbstractMutableVirtualTable(TableMetadata metadata)AbstractVirtualTable(TableMetadata metadata)SimpleDataSet(TableMetadata metadata)SimpleTable(TableMetadata metadata, java.util.function.Supplier<AbstractVirtualTable.DataSet> supplier) -
Uses of TableMetadata in org.apache.cassandra.exceptions
Constructors in org.apache.cassandra.exceptions with parameters of type TableMetadata Constructor Description UnknownIndexException(TableMetadata metadata, java.util.UUID id) -
Uses of TableMetadata in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type TableMetadata Modifier and Type Method Description static IndexRegistryIndexRegistry. obtain(TableMetadata table)Returns theIndexRegistryassociated to the specified table.static Pair<ColumnMetadata,IndexTarget.Type>TargetParser. parse(TableMetadata metadata, java.lang.String target)static Pair<ColumnMetadata,IndexTarget.Type>TargetParser. parse(TableMetadata metadata, IndexMetadata indexDef) -
Uses of TableMetadata in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal that return TableMetadata Modifier and Type Method Description static TableMetadataCassandraIndex. indexCfsMetadata(TableMetadata baseCfsMetadata, IndexMetadata indexMetadata)Construct the TableMetadata for an index table, the clustering columns in the index table vary dependent on the kind of the indexed value.Methods in org.apache.cassandra.index.internal with parameters of type TableMetadata Modifier and Type Method Description default TableMetadata.BuilderCassandraIndexFunctions. addIndexClusteringColumns(TableMetadata.Builder builder, TableMetadata baseMetadata, ColumnMetadata cfDef)Add the clustering columns for a specific type of index table to the a TableMetadata.Builder (which is being used to construct the index table's TableMetadata.static TableMetadataCassandraIndex. indexCfsMetadata(TableMetadata baseCfsMetadata, IndexMetadata indexMetadata)Construct the TableMetadata for an index table, the clustering columns in the index table vary dependent on the kind of the indexed value. -
Uses of TableMetadata in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type TableMetadata Modifier and Type Method Description static java.util.Map<java.lang.String,java.lang.String>SASIIndex. validateOptions(java.util.Map<java.lang.String,java.lang.String> options, TableMetadata metadata)Called via reflection atIndexMetadata.validateCustomIndexOptions(org.apache.cassandra.schema.TableMetadata, java.lang.Class<? extends org.apache.cassandra.index.Index>, java.util.Map<java.lang.String, java.lang.String>) -
Uses of TableMetadata in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan that return TableMetadata Modifier and Type Method Description TableMetadataQueryController. metadata() -
Uses of TableMetadata in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable with type parameters of type TableMetadata Modifier and Type Field Description protected java.util.function.Function<Descriptor,TableMetadata>SSTableHeaderFix. schemaCallbackMethods in org.apache.cassandra.io.sstable that return TableMetadata Modifier and Type Method Description TableMetadataSSTable. metadata()TableMetadataSSTableIdentityIterator. metadata()Methods in org.apache.cassandra.io.sstable with parameters of type TableMetadata Modifier and Type Method Description static SSTableSimpleIteratorSSTableSimpleIterator. create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)static SSTableSimpleIteratorSSTableSimpleIterator. createTombstoneOnly(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)Method parameters in org.apache.cassandra.io.sstable with type arguments of type TableMetadata Modifier and Type Method Description SSTableHeaderFix.BuilderSSTableHeaderFix.Builder. schemaCallback(java.util.function.Supplier<java.util.function.Function<Descriptor,TableMetadata>> schemaCallback)Schema callback to retrieve the schema of a table.Constructors in org.apache.cassandra.io.sstable with parameters of type TableMetadata Constructor Description EmptySSTableSimpleIterator(TableMetadata metadata)KeyIterator(Descriptor desc, TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as TableMetadata Modifier and Type Field Description protected TableMetadataSSTableReaderBuilder. metadataMethods in org.apache.cassandra.io.sstable.format with parameters of type TableMetadata Modifier and Type Method Description RowIndexEntry.IndexSerializer<?>SSTableFormat. getIndexSerializer(TableMetadata metadata, Version version, SerializationHeader header)static voidSSTableWriter. guardCollectionSize(TableMetadata metadata, DecoratedKey partitionKey, Unfiltered unfiltered) -
Uses of TableMetadata in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big that return TableMetadata Modifier and Type Method Description TableMetadataBigTableScanner.EmptySSTableScanner. metadata()TableMetadataBigTableScanner. metadata()Methods in org.apache.cassandra.io.sstable.format.big with parameters of type TableMetadata Modifier and Type Method Description RowIndexEntry.IndexSerializerBigFormat. getIndexSerializer(TableMetadata metadata, Version version, SerializationHeader header) -
Uses of TableMetadata in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator with parameters of type TableMetadata Modifier and Type Method Description static EndpointsForTokenEndpointsForToken. natural(TableMetadata table, Token token)static EndpointsForTokenEndpointsForToken. pending(TableMetadata table, Token token) -
Uses of TableMetadata in org.apache.cassandra.metrics
Methods in org.apache.cassandra.metrics with parameters of type TableMetadata Modifier and Type Method Description java.util.Map<java.lang.String,java.lang.Long>TopPartitionTracker.TopHolder. toMap(TableMetadata metadata)Constructors in org.apache.cassandra.metrics with parameters of type TableMetadata Constructor Description TopPartitionTracker(TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.repair.consistent
Methods in org.apache.cassandra.repair.consistent that return TableMetadata Modifier and Type Method Description protected TableMetadataLocalSessions. getTableMetadata(TableId tableId) -
Uses of TableMetadata in org.apache.cassandra.schema
Subclasses of TableMetadata in org.apache.cassandra.schema Modifier and Type Class Description static classTableMetadata.CompactTableMetadataFields in org.apache.cassandra.schema declared as TableMetadata Modifier and Type Field Description TableMetadataViewMetadata. metadatastatic TableMetadataSystemDistributedKeyspace. PartitionDenylistTableMethods in org.apache.cassandra.schema that return TableMetadata Modifier and Type Method Description TableMetadataViewMetadata. baseTableMetadata()TableMetadataTableMetadata.Builder. build()TableMetadataTableMetadataRef. get()default TableMetadataSchemaProvider. getExistingTableMetadata(TableId id)TableMetadataTableMetadataRef. getLocal()Returns node-local table metadataTableMetadataTables. getNullable(java.lang.String name)Get the table with the specified nameTableMetadataSchema. getTableMetadata(java.lang.String keyspace, java.lang.String table)Given a keyspace name and table name, get the table meta data.TableMetadataSchema. getTableMetadata(Descriptor descriptor)TableMetadataSchema. getTableMetadata(TableId id)TableMetadataSchemaProvider. getTableMetadata(java.lang.String keyspace, java.lang.String table)TableMetadataSchemaProvider. getTableMetadata(TableId id)TableMetadataKeyspaceMetadata. getTableNullable(java.lang.String tableName)TableMetadataKeyspaceMetadata. getTableOrViewNullable(java.lang.String tableOrViewName)TableMetadataKeyspaces. getTableOrViewNullable(TableId id)static TableMetadataTableMetadata. minimal(java.lang.String keyspace, java.lang.String name)There is a couple of places in the code where we need a TableMetadata object and don't have one readily available and know that only the keyspace and name matter.TableMetadataTableMetadata. updateIndexTableMetadata(TableParams baseTableParams)TableMetadataSchema. validateTable(java.lang.String keyspaceName, java.lang.String tableName)TableMetadataTableMetadata. withSwapped(java.util.Set<TableMetadata.Flag> flags)TableMetadataTableMetadata. withSwapped(Indexes indexes)TableMetadataTableMetadata. withSwapped(TableParams params)TableMetadataTableMetadata. withSwapped(Triggers triggers)TableMetadataTableMetadata. withUpdatedUserType(UserType udt)Methods in org.apache.cassandra.schema that return types with arguments of type TableMetadata Modifier and Type Method Description java.util.Optional<TableMetadata>KeyspaceMetadata. findIndexedTable(java.lang.String indexName)java.util.Optional<TableMetadata>Tables. get(java.lang.String name)Get the table with the specified namejava.lang.Iterable<TableMetadata>Schema. getTablesAndViews(java.lang.String keyspaceName)Get metadata about keyspace inner ColumnFamiliesjava.util.Iterator<TableMetadata>Tables. iterator()java.lang.Iterable<TableMetadata>Tables. referencingUserType(java.nio.ByteBuffer name)java.util.stream.Stream<TableMetadata>Tables. stream()java.lang.Iterable<TableMetadata>KeyspaceMetadata. tablesAndViews()Methods in org.apache.cassandra.schema with parameters of type TableMetadata Modifier and Type Method Description Tables.BuilderTables.Builder. add(TableMetadata table)Tables.BuilderTables.Builder. add(TableMetadata... tables)static SchemaTransformationSchemaTransformations. addTable(TableMetadata table, boolean ignoreIfExists)Creates a schema transformation that adds the provided table.voidIndexMetadata. appendCqlTo(CqlBuilder builder, TableMetadata table, boolean ifNotExists)Appends to the specified builder the CQL used to create this index.static ColumnMetadataColumnMetadata. clusteringColumn(TableMetadata table, java.nio.ByteBuffer name, AbstractType<?> type, int position)ViewMetadataViewMetadata. copy(TableMetadata newMetadata)IndexMetadataIndexMetadata.Serializer. deserialize(DataInputPlus in, int version, TableMetadata table)static TableMetadataRefTableMetadataRef. forOfflineTools(TableMetadata metadata)Create a new ref to the passedTableMetadatafor use by offline tools only.Selector.FactoryColumnMetadata. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames)static TablesTables. of(TableMetadata... tables)default voidSchemaChangeListener. onAlterTable(TableMetadata before, TableMetadata after, boolean affectStatements)default voidSchemaChangeListener. onCreateTable(TableMetadata table)default voidSchemaChangeListener. onDropTable(TableMetadata table, boolean dropData)default voidSchemaChangeListener. onPreAlterTable(TableMetadata before, TableMetadata after)static ColumnMetadataColumnMetadata. partitionKeyColumn(TableMetadata table, java.nio.ByteBuffer name, AbstractType<?> type, int position)static ColumnMetadataColumnMetadata. regularColumn(TableMetadata table, java.nio.ByteBuffer name, AbstractType<?> type)voidTableMetadataRef. setLocalOverrides(TableMetadata metadata)static ColumnMetadataColumnMetadata. staticColumn(TableMetadata table, java.nio.ByteBuffer name, AbstractType<?> type)java.lang.StringIndexMetadata. toCqlString(TableMetadata table, boolean ifNotExists)voidIndexes. validate(TableMetadata table)voidIndexMetadata. validate(TableMetadata table)TablesTables. with(TableMetadata table)Create a Tables instance with the provided table addedTablesTables. without(TableMetadata table)TablesTables. withSwapped(TableMetadata table)Method parameters in org.apache.cassandra.schema with type arguments of type TableMetadata Modifier and Type Method Description Tables.BuilderTables.Builder. add(java.lang.Iterable<TableMetadata> tables)TablesTables. filter(java.util.function.Predicate<TableMetadata> predicate)static TablesTables. of(java.lang.Iterable<TableMetadata> tables)Constructors in org.apache.cassandra.schema with parameters of type TableMetadata Constructor Description ColumnMetadata(TableMetadata table, java.nio.ByteBuffer name, AbstractType<?> type, int position, ColumnMetadata.Kind kind)ViewMetadata(TableId baseTableId, java.lang.String baseTableName, boolean includeAllColumns, WhereClause whereClause, TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.service
Methods in org.apache.cassandra.service with parameters of type TableMetadata Modifier and Type Method Description voidClientState. ensureTablePermission(TableMetadata table, Permission perm)voidCacheService. invalidateCounterCacheForCf(TableMetadata tableMetadata)voidCacheService. invalidateKeyCacheForCf(TableMetadata tableMetadata)voidCacheService. invalidateRowCacheForCf(TableMetadata tableMetadata) -
Uses of TableMetadata in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type TableMetadata Modifier and Type Method Description Clustering<?>PagingState.RowMark. clustering(TableMetadata metadata)static PagingState.RowMarkPagingState.RowMark. create(TableMetadata metadata, Row row, ProtocolVersion protocolVersion) -
Uses of TableMetadata in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos with parameters of type TableMetadata Modifier and Type Method Description static PaxosRepairPaxosRepair. create(ConsistencyLevel consistency, DecoratedKey partitionKey, Ballot incompleteBallot, TableMetadata table)static Commit.ProposalCommit.Proposal. empty(Ballot ballot, DecoratedKey partitionKey, TableMetadata metadata)static CommitCommit. emptyCommit(DecoratedKey partitionKey, TableMetadata metadata)static PaxosStatePaxosState. get(DecoratedKey partitionKey, TableMetadata table)static booleanPaxos. isInRangeAndShouldProcess(InetAddressAndPort from, DecoratedKey key, TableMetadata table, boolean includesRead)static PaxosOperationLockPaxosState. lock(DecoratedKey partitionKey, TableMetadata metadata, long deadline, ConsistencyLevel consistencyForConsensus, boolean isWrite)static CommitCommit. newPrepare(DecoratedKey partitionKey, TableMetadata metadata, Ballot ballot)static Commit.AcceptedCommit.Accepted. none(DecoratedKey partitionKey, TableMetadata metadata)static Commit.CommittedCommit.Committed. none(DecoratedKey partitionKey, TableMetadata metadata)static PaxosState.SnapshotPaxosState. unsafeGetIfPresent(DecoratedKey partitionKey, TableMetadata metadata)static booleanPaxosRepair. validatePeerCompatibility(TableMetadata table, java.util.Collection<Range<Token>> ranges)Constructors in org.apache.cassandra.service.paxos with parameters of type TableMetadata Constructor Description Key(DecoratedKey partitionKey, TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.service.paxos.cleanup
Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type TableMetadata Modifier and Type Method Description static PaxosCleanupPaxosCleanup. cleanup(java.util.Collection<InetAddressAndPort> endpoints, TableMetadata table, java.util.Collection<Range<Token>> ranges, boolean skippedReplicas, java.util.concurrent.Executor executor)Constructors in org.apache.cassandra.service.paxos.cleanup with parameters of type TableMetadata Constructor Description PaxosCleanup(java.util.Collection<InetAddressAndPort> endpoints, TableMetadata table, java.util.Collection<Range<Token>> ranges, boolean skippedReplicas, java.util.concurrent.Executor executor) -
Uses of TableMetadata in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type TableMetadata Modifier and Type Method Description static Commit.CommittedPaxosRows. getCommitted(TableMetadata metadata, DecoratedKey partitionKey, Row row, long purgeBefore, long overrideTtlSeconds) -
Uses of TableMetadata in org.apache.cassandra.service.paxos.v1
Methods in org.apache.cassandra.service.paxos.v1 with parameters of type TableMetadata Modifier and Type Method Description java.lang.Iterable<InetAddressAndPort>PrepareCallback. replicasMissingMostRecentCommit(TableMetadata metadata)Constructors in org.apache.cassandra.service.paxos.v1 with parameters of type TableMetadata Constructor Description PrepareCallback(DecoratedKey key, TableMetadata metadata, int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime) -
Uses of TableMetadata in org.apache.cassandra.service.reads.range
Methods in org.apache.cassandra.service.reads.range with parameters of type TableMetadata Modifier and Type Method Description static booleanRangeCommands. sufficientLiveNodesForSelectStar(TableMetadata metadata, ConsistencyLevel consistency)Added specifically to check for sufficient nodes live to serve partition denylist queries -
Uses of TableMetadata in org.apache.cassandra.tools
Methods in org.apache.cassandra.tools that return TableMetadata Modifier and Type Method Description static TableMetadataUtil. metadataFromSSTable(Descriptor desc)Construct table schema from info stored in SSTable's Stats.dbMethods in org.apache.cassandra.tools with parameters of type TableMetadata Modifier and Type Method Description static voidJsonTransformer. keysToJson(ISSTableScanner currentScanner, java.util.stream.Stream<DecoratedKey> keys, boolean rawTime, TableMetadata metadata, java.io.OutputStream out)static voidJsonTransformer. toJson(ISSTableScanner currentScanner, java.util.stream.Stream<UnfilteredRowIterator> partitions, boolean rawTime, TableMetadata metadata, java.io.OutputStream out)static voidJsonTransformer. toJsonLines(ISSTableScanner currentScanner, java.util.stream.Stream<UnfilteredRowIterator> partitions, boolean rawTime, TableMetadata metadata, java.io.OutputStream out) -
Uses of TableMetadata in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport with parameters of type TableMetadata Modifier and Type Method Description voidServer.EventNotifier. onAlterTable(TableMetadata before, TableMetadata after, boolean affectsStatements)voidServer.EventNotifier. onCreateTable(TableMetadata table)voidServer.EventNotifier. onDropTable(TableMetadata table, boolean dropData) -
Uses of TableMetadata in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils with parameters of type TableMetadata Modifier and Type Method Description static voidDiagnosticSnapshotService. duplicateRows(TableMetadata metadata, java.lang.Iterable<InetAddressAndPort> replicas)static voidDiagnosticSnapshotService. repairedDataMismatch(TableMetadata metadata, java.lang.Iterable<InetAddressAndPort> replicas)
-