Uses of Class
org.apache.cassandra.schema.TableMetadata
Packages that use TableMetadata
Package
Description
File transfer
-
Uses of TableMetadata in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth with parameters of type TableMetadataModifier and TypeMethodDescriptionvoidAuthSchemaChangeListener.onDropTable(TableMetadata table, boolean dropData) -
Uses of TableMetadata in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic CounterCacheKeyCounterCacheKey.create(TableMetadata tableMetadata, 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 TableMetadataModifierConstructorDescriptionCacheKey(TableMetadata metadata) KeyCacheKey(TableMetadata tableMetadata, Descriptor desc, ByteBuffer key) RowCacheKey(TableMetadata metadata, DecoratedKey key) -
Uses of TableMetadata in org.apache.cassandra.cql3
Fields in org.apache.cassandra.cql3 declared as TableMetadataMethods in org.apache.cassandra.cql3 with parameters of type TableMetadataModifier and TypeMethodDescriptionOrdering.Raw.Ann.bind(TableMetadata table, VariableSpecifications boundNames) Ordering.Raw.bind(TableMetadata table, VariableSpecifications boundNames) Resolves column identifiers against the table schema.Ordering.Raw.Expression.bind(TableMetadata table, VariableSpecifications boundNames) Ordering.Raw.SingleColumn.bind(TableMetadata table, VariableSpecifications boundNames) 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) Operation.Addition.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.ColumnDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) Operation.ElementDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) Operation.FieldDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) Operation.Prepend.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.RawDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) This method validates the operation (i.e.Operation.RawUpdate.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) This method validates the operation (i.e.Operation.SetElement.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.SetField.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.SetValue.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.Substraction.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Json.Literal.prepareAndCollectMarkers(TableMetadata metadata, Collection<ColumnMetadata> receivers, VariableSpecifications boundNames) Json.Marker.prepareAndCollectMarkers(TableMetadata metadata, Collection<ColumnMetadata> receivers, VariableSpecifications boundNames) Json.Raw.prepareAndCollectMarkers(TableMetadata metadata, Collection<ColumnMetadata> receivers, VariableSpecifications boundNames) protected List<ColumnMetadata>MultiColumnRelation.receivers(TableMetadata table) final RestrictionRelation.toRestriction(TableMetadata table, VariableSpecifications boundNames) Converts thisRelationinto aRestriction.static voidValidation.validateKey(TableMetadata metadata, ByteBuffer key) Validates a (full serialized) partition key.Constructors in org.apache.cassandra.cql3 with parameters of type TableMetadataModifierConstructorDescriptionUpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, long nowInSec, int ttl, Map<DecoratedKey, Partition> prefetchedRows) -
Uses of TableMetadata in org.apache.cassandra.cql3.conditions
Methods in org.apache.cassandra.cql3.conditions with parameters of type TableMetadataModifier and TypeMethodDescriptionColumnCondition.Raw.prepare(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 -
Uses of TableMetadata in org.apache.cassandra.cql3.restrictions
Fields in org.apache.cassandra.cql3.restrictions declared as TableMetadataModifier and TypeFieldDescriptionprotected final TableMetadataTokenRestriction.metadatafinal TableMetadataStatementRestrictions.tableThe Column Family meta dataMethods in org.apache.cassandra.cql3.restrictions with parameters of type TableMetadataModifier and TypeMethodDescriptionvoidCustomIndexExpression.addToRowFilter(RowFilter filter, TableMetadata table, QueryOptions options) static StatementRestrictionsStatementRestrictions.empty(StatementType type, TableMetadata table) Creates a new emptyStatementRestrictions.booleanTokenRestriction.hasUnrestrictedPartitionKeyComponents(TableMetadata table) booleanStatementRestrictions.needFiltering(TableMetadata table) Checks if the query need to use filtering.booleanTokenRestriction.needFiltering(TableMetadata table) voidCustomIndexExpression.prepareValue(TableMetadata table, AbstractType<?> expressionType, VariableSpecifications boundNames) Constructors in org.apache.cassandra.cql3.restrictions with parameters of type TableMetadataModifierConstructorDescriptionEQRestriction(TableMetadata table, List<ColumnMetadata> columnDefs, Term value) SliceRestriction(TableMetadata table, List<ColumnMetadata> columnDefs, Bound bound, boolean inclusive, Term term) StatementRestrictions(ClientState state, StatementType type, TableMetadata table, WhereClause whereClause, VariableSpecifications boundNames, List<Ordering> orderings, boolean selectsOnlyStaticColumns, boolean allowFiltering, boolean forView) StatementRestrictions(ClientState state, StatementType type, TableMetadata table, WhereClause whereClause, VariableSpecifications boundNames, List<Ordering> orderings, boolean selectsOnlyStaticColumns, boolean allowUseOfSecondaryIndices, boolean allowFiltering, boolean forView) TokenRestriction(TableMetadata metadata, 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 TableMetadataModifier and TypeMethodDescriptionSelectable.RawIdentifier.columnMetadata(TableMetadata cfm) protected abstract SelectorSelector.SelectorDeserializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) Selector.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) static SelectionSelection.forColumns(TableMetadata table, List<ColumnMetadata> columns, boolean returnStaticContentOnPartitionWithNoRows) static SelectionSelection.fromSelectors(TableMetadata table, List<Selectable> selectables, VariableSpecifications boundNames, Set<ColumnMetadata> orderingColumns, Set<ColumnMetadata> nonPKRestrictedColumns, boolean hasGroupBy, boolean isJson, boolean returnStaticContentOnPartitionWithNoRows) Selector.Factory.getColumnSpecification(TableMetadata table) Returns the column specification corresponding to the output value of the selector instances created by this factory.Selectable.BetweenParenthesesOrWithTuple.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithArrayLiteral.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithCast.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithElementSelection.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithFieldSelection.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithFunction.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithList.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithMapOrUdt.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithSet.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithSliceSelection.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithTerm.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithTypeHint.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WithVector.newSelectorFactory(TableMetadata cfm, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.WritetimeOrTTL.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) Selectable.BetweenParenthesesOrWithTuple.Raw.prepare(TableMetadata cfm) Selectable.Raw.prepare(TableMetadata table) Selectable.RawIdentifier.prepare(TableMetadata cfm) Selectable.WithArrayLiteral.Raw.prepare(TableMetadata cfm) Selectable.WithCast.Raw.prepare(TableMetadata table) Selectable.WithElementSelection.Raw.prepare(TableMetadata cfm) Selectable.WithFieldSelection.Raw.prepare(TableMetadata table) Selectable.WithFunction.Raw.prepare(TableMetadata table) Selectable.WithMapOrUdt.Raw.prepare(TableMetadata cfm) Selectable.WithSet.Raw.prepare(TableMetadata cfm) Selectable.WithSliceSelection.Raw.prepare(TableMetadata cfm) Selectable.WithTerm.Raw.prepare(TableMetadata table) Selectable.WithTypeHint.Raw.prepare(TableMetadata cfm) Selectable.WritetimeOrTTL.Raw.prepare(TableMetadata table) protected final AbstractType<?>Selector.SelectorDeserializer.readType(TableMetadata metadata, DataInputPlus in) static List<Selectable>RawSelector.toSelectables(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.wildcardWithGroupByOrMaskedColumns(TableMetadata table, VariableSpecifications boundNames, Set<ColumnMetadata> orderingColumns, boolean isJson, boolean returnStaticContentOnPartitionWithNoRows) Constructors in org.apache.cassandra.cql3.selection with parameters of type TableMetadataModifierConstructorDescriptionprotectedSelection(TableMetadata table, List<ColumnMetadata> selectedColumns, Set<ColumnMetadata> orderingColumns, SelectionColumnMapping columnMapping, org.apache.cassandra.cql3.selection.ColumnFilterFactory columnFilterFactory, boolean isJson) WithMapOrUdt(TableMetadata cfm, 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 TableMetadataModifier and TypeFieldDescriptionfinal TableMetadataCQL3CasRequest.metadatafinal TableMetadataModificationStatement.metadatafinal TableMetadataSelectStatement.tableMethods in org.apache.cassandra.cql3.statements that return TableMetadataMethods in org.apache.cassandra.cql3.statements with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic ByteBuffer[]SelectStatement.getComponents(TableMetadata metadata, DecoratedKey dk) UpdatesCollector.getPartitionUpdateBuilder(TableMetadata metadata, DecoratedKey dk, ConsistencyLevel consistency) protected StatementRestrictionsModificationStatement.Parsed.newRestrictions(ClientState state, TableMetadata metadata, VariableSpecifications boundNames, Operations operations, WhereClause where, Conditions conditions, List<Ordering> orderings) Creates the restrictions.protected ModificationStatementDeleteStatement.Parsed.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected abstract ModificationStatementModificationStatement.Parsed.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected ModificationStatementUpdateStatement.ParsedInsert.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected ModificationStatementUpdateStatement.ParsedInsertJson.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected ModificationStatementUpdateStatement.ParsedUpdate.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) static SlicesModificationStatement.toSlices(TableMetadata metadata, SortedSet<ClusteringBound<?>> startBounds, SortedSet<ClusteringBound<?>> endBounds) Constructors in org.apache.cassandra.cql3.statements with parameters of type TableMetadataModifierConstructorDescriptionCQL3CasRequest(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, org.apache.cassandra.cql3.statements.SelectStatement.ColumnComparator<List<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 TableMetadataModifier and TypeMethodDescriptionAlterTableStatement.AlterColumn.apply(KeyspaceMetadata keyspace, TableMetadata table) AlterTableStatement.MaskColumn.apply(KeyspaceMetadata keyspace, TableMetadata table) IndexTarget.Raw.prepare(TableMetadata table) -
Uses of TableMetadata in org.apache.cassandra.db
Fields in org.apache.cassandra.db declared as TableMetadataModifier and TypeFieldDescriptionstatic final TableMetadataSystemKeyspace.Batchesprotected final TableMetadataUnfilteredDeserializer.metadataMethods in org.apache.cassandra.db that return TableMetadataModifier and TypeMethodDescriptionColumnFamilyStore.metadata()ReadExecutionController.metadata()ReadQuery.metadata()The metadata for the table this is a query on.SimpleBuilders.PartitionUpdateBuilder.metadata()SinglePartitionReadQuery.Group.metadata()Methods in org.apache.cassandra.db with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic PartitionRangeReadCommandPartitionRangeReadCommand.allDataRead(TableMetadata metadata, long nowInSec) Creates a new read command that query all the data in the table.static PartitionRangeReadCommandPartitionRangeReadCommand.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange) static ReadQueryPartitionRangeReadQuery.create(TableMetadata table, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange) static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, ByteBuffer key, Slices slices) Creates a new single partition slice command for the provided slices.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, NavigableSet<Clustering<?>> names) Creates a new single partition name command for the provided rows.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, Clustering<?> name) Creates a new single partition name command for the provided row.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter) Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, Slice slice) Creates a new single partition slice command for the provided single slice.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, Slices slices) Creates a new single partition slice command for the provided slices.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long 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, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan) Creates a new read command on a single partition.SinglePartitionReadCommand.Group.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter) static SinglePartitionReadQuerySinglePartitionReadQuery.create(TableMetadata metadata, long nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter) Creates a new read query on a single partition.static SinglePartitionReadQuerySinglePartitionReadQuery.create(TableMetadata metadata, long 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, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter) Columns.Serializer.deserialize(DataInputPlus in, TableMetadata metadata) DataRange.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) abstract ReadCommandReadCommand.SelectionDeserializer.deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan) Slices.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) SerializationHeader.Serializer.deserializeForMessaging(DataInputPlus in, TableMetadata metadata, ColumnFilter selection, boolean hasStatic) static ReadQueryReadQuery.empty(TableMetadata metadata) static SinglePartitionReadCommandSinglePartitionReadCommand.fullPartitionRead(TableMetadata metadata, long nowInSec, ByteBuffer key) Creates a new read command that queries a single partition in its entirety.static SinglePartitionReadCommandSinglePartitionReadCommand.fullPartitionRead(TableMetadata metadata, long nowInSec, DecoratedKey key) Creates a new read command that queries a single partition in its entirety.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.SchemaCQLHelper.getIndexesAsCQL(TableMetadata metadata, boolean ifNotExists) Build a CQL String representation of Indexes on columns in the given Column FamilyMutation.getPartitionUpdate(TableMetadata table) static StringSchemaCQLHelper.getTableMetadataAsCQL(TableMetadata metadata, KeyspaceMetadata keyspaceMetadata) Build a CQL String representation of Column Family Metadata.SystemKeyspace.getTopPartitions(TableMetadata metadata, String topType) 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, 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, long 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, 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) 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, String topType, 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 StringClustering.toCQLString(TableMetadata metadata) DataRange.toCQLString(TableMetadata metadata, RowFilter rowFilter) DecoratedKey.toCQLString(TableMetadata metadata) Returns a CQL representation of this key.abstract StringSlices.toCQLString(TableMetadata metadata, RowFilter rowFilter) SerializationHeader.Component.toHeader(TableMetadata metadata) default StringClustering.toString(TableMetadata metadata) default StringClusteringBoundOrBoundary.toString(TableMetadata metadata) ClusteringPrefix.toString(TableMetadata metadata) Generates a proper string representation of the prefix.DataRange.Paging.toString(TableMetadata metadata) DataRange.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) Mutation.SimpleBuilder.update(TableMetadata metadata) Adds an update for table identified by the provided metadata and return a builder for that partition.SimpleBuilders.MutationBuilder.update(TableMetadata metadata) voidConsistencyLevel.validateCounterForWrite(TableMetadata metadata) Constructors in org.apache.cassandra.db with parameters of type TableMetadataModifierConstructorDescriptionDirectories(TableMetadata metadata) Directories(TableMetadata metadata, Collection<Directories.DataDirectory> paths) Directories(TableMetadata metadata, Directories.DataDirectory[] paths) Create Directories of given ColumnFamily.protectedPartitionRangeReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange, Index.QueryPlan indexQueryPlan, boolean trackWarnings) PartitionUpdateBuilder(TableMetadata metadata, Object... partitionKeyValues) protectedReadCommand(ReadCommand.Kind kind, boolean isDigestQuery, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange) RowBuilder(TableMetadata metadata, Object... clusteringColumns) SerializationHeader(boolean isForSSTable, TableMetadata metadata, RegularAndStaticColumns columns, EncodingStats stats) protectedSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange) protectedVirtualTableSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange) -
Uses of TableMetadata in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation with parameters of type TableMetadataModifier and TypeMethodDescriptionAggregationSpecification.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction that return TableMetadataModifier and TypeMethodDescriptionUnifiedCompactionStrategy.getMetadata()CompactionInfo.getTableMetadata()CompactionIterator.metadata()Methods in org.apache.cassandra.db.compaction with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic 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 where we don't know the sstables at constructionstatic CompactionInfoCompactionInfo.withoutSSTables(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId, String targetDirectory) Special compaction info where we always need to cancel the compaction - for example AutoSavingCache where we don't know the sstables at constructionMethod parameters in org.apache.cassandra.db.compaction with type arguments of type TableMetadataModifier and TypeMethodDescriptionCompactionManager.getCompactionsMatching(Iterable<TableMetadata> columnFamilies, Predicate<CompactionInfo> predicate) voidCompactionManager.interruptCompactionFor(Iterable<TableMetadata> columnFamilies, 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 TableMetadataModifierConstructorDescriptionCompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, CompactionInfo.Unit unit, TimeUUID compactionId, Collection<? extends SSTableReader> sstables, String targetDirectory) CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, TimeUUID compactionId, Collection<? extends SSTableReader> sstables) CompactionInfo(TableMetadata metadata, OperationType tasktype, long completed, long total, TimeUUID compactionId, Collection<SSTableReader> sstables, String targetDirectory) -
Uses of TableMetadata in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter with parameters of type TableMetadataModifier and TypeMethodDescriptionvoidRowFilter.addCustomIndexExpression(TableMetadata metadata, IndexMetadata targetIndex, 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, StringBuilder sb) ClusteringIndexFilter.InternalDeserializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, boolean reversed) ClusteringIndexFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) ColumnFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) ColumnSubselection.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) DataLimits.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) RowFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, boolean needsReconciliation) protected abstract RowFilter.UserExpressionRowFilter.UserExpression.Deserializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) RowFilter.filter(PartitionIterator iter, TableMetadata metadata, long nowInSec) Filters the provided iterator so that only the row satisfying the expression of this filter are included in the resulting iterator.protected Transformation<BaseRowIterator<?>>RowFilter.filter(TableMetadata metadata, long nowInSec) Note that the application of this transformation does not yet takeRowFilter.isStrict()into account.ClusteringIndexFilter.getSlices(TableMetadata metadata) ClusteringIndexNamesFilter.getSlices(TableMetadata metadata) ClusteringIndexSliceFilter.getSlices(TableMetadata metadata) protected ByteBufferRowFilter.Expression.getValue(TableMetadata metadata, DecoratedKey partitionKey, Row row, long nowInSec) booleanRowFilter.CustomExpression.isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, long nowInSec) abstract booleanRowFilter.Expression.isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, long nowInSec) Returns whether the provided row satisfied this expression or not.booleanRowFilter.isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, long nowInSec) Whether the provided row in the provided partition satisfies this filter.booleanRowFilter.SimpleExpression.isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, long nowInSec) ColumnFilter.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.ClusteringIndexFilter.toCQLString(TableMetadata metadata, RowFilter rowFilter) ClusteringIndexNamesFilter.toCQLString(TableMetadata metadata, RowFilter rowFilter) ClusteringIndexSliceFilter.toCQLString(TableMetadata metadata, RowFilter rowFilter) ClusteringIndexFilter.toString(TableMetadata metadata) ClusteringIndexNamesFilter.toString(TableMetadata metadata) ClusteringIndexSliceFilter.toString(TableMetadata metadata) Constructors in org.apache.cassandra.db.filter with parameters of type TableMetadataModifierConstructorDescriptionCustomExpression(TableMetadata table, IndexMetadata targetIndex, ByteBuffer value) TombstoneOverwhelmingException(int numTombstones, 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 TableMetadataModifier and TypeMethodDescriptionstatic booleanLifecycleTransaction.removeUnfinishedLeftovers(TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable that return TableMetadataModifier and TypeMethodDescriptionAbstractMemtable.metadata()default TableMetadataMemtable.FlushablePartitionSet.metadata()Memtable.metadata()The table's definition metadata.ShardedSkipListMemtable.MemtableUnfilteredPartitionIterator.metadata()Constructors in org.apache.cassandra.db.memtable with parameters of type TableMetadataModifierConstructorDescriptionMemtableUnfilteredPartitionIterator(TableMetadata metadata, 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 TableMetadataMethods in org.apache.cassandra.db.partitions that return TableMetadataModifier and TypeMethodDescriptionabstract TableMetadataAbstractBTreePartition.metadata()AtomicBTreePartition.metadata()ImmutableBTreePartition.metadata()Partition.metadata()PartitionUpdate.Builder.metadata()PartitionUpdate.metadata()PartitionUpdate.SimpleBuilder.metadata()The metadata of the table this is a builder on.SingletonUnfilteredPartitionIterator.metadata()UnfilteredPartitionIterator.metadata()Methods in org.apache.cassandra.db.partitions with parameters of type TableMetadataModifier and TypeMethodDescriptionUnfilteredPartitionIterators.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, ByteBuffer key, long timestamp, long nowInSec) Creates a partition update that entirely deletes a given partition.static PartitionUpdatePartitionUpdate.fullPartitionDelete(TableMetadata metadata, DecoratedKey key, long timestamp, long nowInSec) Creates an immutable partition update that entirely deletes a given partition.PartitionUpdate.simpleBuilder(TableMetadata metadata, Object... partitionKeyValues) Creates a new simple partition update builder.static PartitionUpdatePartitionUpdate.singleRowUpdate(TableMetadata metadata, 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, BTreePartitionData holder, MutableDeletionInfo deletionInfo, boolean canHaveShadowedData) Constructors in org.apache.cassandra.db.partitions with parameters of type TableMetadataModifierConstructorDescriptionBuilder(TableMetadata metadata, 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) protectedImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, BTreePartitionData holder) ImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, RegularAndStaticColumns columns, Row staticRow, 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 -
Uses of TableMetadata in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as TableMetadataModifier and TypeFieldDescriptionprotected final TableMetadataAbstractUnfilteredRowIterator.metadataMethods in org.apache.cassandra.db.rows that return TableMetadataModifier and TypeMethodDescriptionAbstractUnfilteredRowIterator.metadata()BaseRowIterator.metadata()The metadata for the table this iterator on.LazilyInitializedUnfilteredRowIterator.metadata()UnfilteredRowIteratorWithLowerBound.metadata()default TableMetadataWrappingUnfilteredRowIterator.metadata()Methods in org.apache.cassandra.db.rows with parameters of type TableMetadataModifier and TypeMethodDescriptionBTreeRow.cellsInLegacyOrder(TableMetadata metadata, boolean reversed) Row.cellsInLegacyOrder(TableMetadata metadata, boolean reversed) An iterable over the cells of this row that return cells in "legacy order".UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag) UnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, DeserializationHelper.Flag flag, UnfilteredRowIteratorSerializer.Header header) UnfilteredRowIteratorSerializer.deserializeHeader(TableMetadata metadata, ColumnFilter selection, DataInputPlus in, int version, DeserializationHelper.Flag flag) BTreeRow.filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata) BTreeRow.filter(ColumnFilter filter, TableMetadata metadata) Row.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.Row.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, 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) AbstractRangeTombstoneMarker.toString(TableMetadata metadata, boolean fullDetails) AbstractRangeTombstoneMarker.toString(TableMetadata metadata, boolean includeClusteringKeys, boolean fullDetails) AbstractRow.toString(TableMetadata metadata) AbstractRow.toString(TableMetadata metadata, boolean fullDetails) AbstractRow.toString(TableMetadata metadata, boolean includeClusterKeys, boolean fullDetails) ArtificialBoundMarker.toString(TableMetadata metadata) RangeTombstoneBoundaryMarker.toString(TableMetadata metadata) RangeTombstoneBoundMarker.toString(TableMetadata metadata) Row.toString(TableMetadata metadata, boolean fullDetails) Unfiltered.toString(TableMetadata metadata) Unfiltered.toString(TableMetadata metadata, boolean fullDetails) Unfiltered.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 TableMetadataModifierConstructorDescriptionprotectedAbstractUnfilteredRowIterator(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, Iterator<Row> rows, Iterator<RangeTombstone> ranges, boolean removeShadowedData) -
Uses of TableMetadata in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming that return TableMetadataMethods in org.apache.cassandra.db.streaming with parameters of type TableMetadataModifier and TypeMethodDescriptionprotected 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 TableMetadataModifierConstructorDescriptionStreamDeserializer(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 -
Uses of TableMetadata in org.apache.cassandra.db.virtual
Fields in org.apache.cassandra.db.virtual declared as TableMetadataMethods in org.apache.cassandra.db.virtual that return TableMetadataModifier and TypeMethodDescriptionVirtualKeyspaceRegistry.getTableMetadataNullable(TableId id) AbstractVirtualTable.metadata()VirtualTable.metadata()Returns the view metadata.Methods in org.apache.cassandra.db.virtual with parameters of type TableMetadataModifier and TypeMethodDescriptionAbstractMutableVirtualTable.ColumnValues.from(TableMetadata metadata, ClusteringPrefix<?> prefix) Returns the set of column values corresponding to the specified clustering prefix.AbstractMutableVirtualTable.ColumnValues.from(TableMetadata metadata, DecoratedKey partitionKey) Returns the set of column values corresponding to the specified partition key.AbstractVirtualTable.Partition.toRowIterator(TableMetadata metadata, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter, long now) Constructors in org.apache.cassandra.db.virtual with parameters of type TableMetadataModifierConstructorDescriptionprotectedAbstractMutableVirtualTable(TableMetadata metadata) protectedAbstractVirtualTable(TableMetadata metadata) SimpleDataSet(TableMetadata metadata) SimpleDataSet(TableMetadata metadata, Comparator<DecoratedKey> comparator) SimpleTable(TableMetadata metadata, Supplier<AbstractVirtualTable.DataSet> supplier) -
Uses of TableMetadata in org.apache.cassandra.exceptions
Constructors in org.apache.cassandra.exceptions with parameters of type TableMetadata -
Uses of TableMetadata in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type TableMetadataModifier and TypeMethodDescriptionIndex.Group.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker, TableMetadata tableMetadata) Get flush observer to observe partition/cell events generated by flushing SSTable (memtable flush or compaction).SingletonIndexGroup.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker, TableMetadata tableMetadata) static IndexRegistryIndexRegistry.obtain(TableMetadata table) Returns theIndexRegistryassociated to the specified table.static Pair<ColumnMetadata,IndexTarget.Type> TargetParser.parse(TableMetadata metadata, 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 TableMetadataModifier and TypeMethodDescriptionstatic 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 TableMetadataModifier and TypeMethodDescriptiondefault 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.sai
Methods in org.apache.cassandra.index.sai that return TableMetadataMethods in org.apache.cassandra.index.sai with parameters of type TableMetadataModifier and TypeMethodDescriptionStorageAttachedIndexGroup.getFlushObserver(Descriptor descriptor, LifecycleNewTracker tracker, TableMetadata tableMetadata) StorageAttachedIndex.validateOptions(Map<String, String> options, TableMetadata metadata) Used via reflection inIndexMetadata -
Uses of TableMetadata in org.apache.cassandra.index.sai.metrics
Constructors in org.apache.cassandra.index.sai.metrics with parameters of type TableMetadataModifierConstructorDescriptionIndexGroupMetrics(TableMetadata table, StorageAttachedIndexGroup group) PerQueryMetrics(TableMetadata table) TableQueryMetrics(TableMetadata table) TableStateMetrics(TableMetadata table, StorageAttachedIndexGroup group) -
Uses of TableMetadata in org.apache.cassandra.index.sai.plan
Methods in org.apache.cassandra.index.sai.plan that return TableMetadata -
Uses of TableMetadata in org.apache.cassandra.index.sai.utils
Methods in org.apache.cassandra.index.sai.utils that return TableMetadataMethods in org.apache.cassandra.index.sai.utils with parameters of type TableMetadataModifier and TypeMethodDescriptionRowWithSource.cellsInLegacyOrder(TableMetadata metadata, boolean reversed) RowWithSource.filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata) RowWithSource.filter(ColumnFilter filter, TableMetadata metadata) RowWithSource.toString(TableMetadata metadata) RowWithSource.toString(TableMetadata metadata, boolean fullDetails) RowWithSource.toString(TableMetadata metadata, boolean includeClusterKeys, boolean fullDetails) voidRowWithSource.validateData(TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type TableMetadataModifier and TypeMethodDescriptionSASIIndex.validateOptions(Map<String, 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 -
Uses of TableMetadata in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as TableMetadataMethods in org.apache.cassandra.io.sstable that return TableMetadataModifier and TypeMethodDescriptionAbstractSSTableIterator.metadata()EmptySSTableScanner.metadata()SSTable.metadata()SSTableIdentityIterator.metadata()Methods in org.apache.cassandra.io.sstable with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic 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) Constructors in org.apache.cassandra.io.sstable with parameters of type TableMetadata -
Uses of TableMetadata in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format that return TableMetadataMethods in org.apache.cassandra.io.sstable.format with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic SequentialWriterDataComponent.buildWriter(Descriptor descriptor, TableMetadata metadata, SequentialWriterOption options, MetadataCollector metadataCollector, OperationType operationType, Config.FlushCompression flushCompression) static IFilterFilterComponent.maybeLoadBloomFilter(Descriptor descriptor, Set<Component> components, TableMetadata metadata, ValidationMetadata validationMetadata) Optionally loads a Bloom filter.StatsComponent.serializationHeader(TableMetadata metadata) protected voidSSTableReaderLoadingBuilder.validatePartitioner(TableMetadata metadata, ValidationMetadata validationMetadata) Check if sstable is created using same partitioner. -
Uses of TableMetadata in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic IndexSummaryComponentIndexSummaryComponent.load(File summaryFile, TableMetadata metadata) Load index summary, first key and last key from Summary.db file if it exists.static IndexSummaryComponentIndexSummaryComponent.loadOrDeleteCorrupted(File summaryFile, TableMetadata metadata) -
Uses of TableMetadata in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic 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 TableMetadataConstructors in org.apache.cassandra.metrics with parameters of type TableMetadata -
Uses of TableMetadata in org.apache.cassandra.repair.autorepair
Methods in org.apache.cassandra.repair.autorepair with parameters of type TableMetadataModifier and TypeMethodDescriptionAutoRepairUtils.getAllMVs(AutoRepairConfig.RepairType repairType, Keyspace keyspace, TableMetadata tableMetadata) -
Uses of TableMetadata in org.apache.cassandra.repair.consistent
Methods in org.apache.cassandra.repair.consistent that return TableMetadataModifier and TypeMethodDescriptionprotected TableMetadataLocalSessions.getTableMetadata(TableId tableId) -
Uses of TableMetadata in org.apache.cassandra.schema
Subclasses of TableMetadata in org.apache.cassandra.schemaFields in org.apache.cassandra.schema declared as TableMetadataModifier and TypeFieldDescriptionstatic final TableMetadataSystemDistributedKeyspace.AutoRepairHistorystatic final TableMetadataSystemDistributedKeyspace.AutoRepairPriorityfinal TableMetadataViewMetadata.metadatastatic final TableMetadataSystemDistributedKeyspace.PartitionDenylistTableMethods in org.apache.cassandra.schema that return TableMetadataModifier and TypeMethodDescriptionViewMetadata.baseTableMetadata()TableMetadata.Builder.build()TableMetadataRef.get()default TableMetadataSchemaProvider.getExistingTableMetadata(TableId id) TableMetadataRef.getLocal()Returns node-local table metadataTables.getNullable(String name) Get the table with the specified nameTables.getNullable(TableId id) Schema.getTableMetadata(String keyspace, String table) Given a keyspace name and table name, get the table meta data.Schema.getTableMetadata(Descriptor descriptor) Schema.getTableMetadata(TableId id) SchemaProvider.getTableMetadata(String keyspace, String table) SchemaProvider.getTableMetadata(TableId id) KeyspaceMetadata.getTableNullable(String tableName) KeyspaceMetadata.getTableOrViewNullable(String tableOrViewName) Keyspaces.getTableOrViewNullable(TableId id) static TableMetadataThere 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.TableMetadata.updateIndexTableMetadata(TableParams baseTableParams) Schema.validateTable(String keyspaceName, String tableName) TableMetadata.withSwapped(Set<TableMetadata.Flag> flags) TableMetadata.withSwapped(Indexes indexes) TableMetadata.withSwapped(TableParams params) TableMetadata.withSwapped(Triggers triggers) TableMetadata.withUpdatedUserType(UserType udt) Methods in org.apache.cassandra.schema that return types with arguments of type TableMetadataModifier and TypeMethodDescriptionKeyspaceMetadata.findIndexedTable(String indexName) Get the table with the specified nameSchema.getTablesAndViews(String keyspaceName) Get metadata about keyspace inner ColumnFamiliesTables.iterator()Tables.referencingUserType(ByteBuffer name) Tables.stream()KeyspaceMetadata.tablesAndViews()KeyspaceMetadata.tablesUsingFunction(Function function) Methods in org.apache.cassandra.schema with parameters of type TableMetadataModifier and TypeMethodDescriptionTables.Builder.add(TableMetadata table) Tables.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, ByteBuffer name, AbstractType<?> type, int position) ViewMetadata.copy(TableMetadata newMetadata) IndexMetadata.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.ColumnMetadata.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, 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, ByteBuffer name, AbstractType<?> type, int position) static ColumnMetadataColumnMetadata.regularColumn(TableMetadata table, ByteBuffer name, AbstractType<?> type) voidTableMetadataRef.setLocalOverrides(TableMetadata metadata) static ColumnMetadataColumnMetadata.staticColumn(TableMetadata table, ByteBuffer name, AbstractType<?> type) IndexMetadata.toCqlString(TableMetadata table, boolean ifNotExists) voidIndexes.validate(TableMetadata table) voidIndexMetadata.validate(TableMetadata table) voidTableMetadata.validateCompatibility(TableMetadata previous) Tables.with(TableMetadata table) Create a Tables instance with the provided table addedTables.without(TableMetadata table) Tables.withSwapped(TableMetadata table) Method parameters in org.apache.cassandra.schema with type arguments of type TableMetadataModifier and TypeMethodDescriptionTables.Builder.add(Iterable<TableMetadata> tables) Tables.filter(Predicate<TableMetadata> predicate) static TablesTables.of(Iterable<TableMetadata> tables) Constructors in org.apache.cassandra.schema with parameters of type TableMetadataModifierConstructorDescriptionColumnMetadata(TableMetadata table, ByteBuffer name, AbstractType<?> type, int position, ColumnMetadata.Kind kind, ColumnMask mask) ViewMetadata(TableId baseTableId, 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 TableMetadataModifier and TypeMethodDescriptionvoidClientState.ensureTablePermission(TableMetadata table, Permission perm) booleanClientState.hasTablePermission(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 TableMetadataModifier and TypeMethodDescriptionClustering<?>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 TableMetadataModifier and TypeMethodDescriptionstatic 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(SharedContext ctx, TableMetadata table, Collection<Range<Token>> ranges) Constructors in org.apache.cassandra.service.paxos with parameters of type TableMetadata -
Uses of TableMetadata in org.apache.cassandra.service.paxos.cleanup
Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic PaxosCleanupPaxosCleanup.cleanup(SharedContext ctx, Collection<InetAddressAndPort> endpoints, TableMetadata table, Collection<Range<Token>> ranges, boolean skippedReplicas, Executor executor) Constructors in org.apache.cassandra.service.paxos.cleanup with parameters of type TableMetadataModifierConstructorDescriptionPaxosCleanup(SharedContext ctx, Collection<InetAddressAndPort> endpoints, TableMetadata table, Collection<Range<Token>> ranges, boolean skippedReplicas, Executor executor) -
Uses of TableMetadata in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic 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 TableMetadataModifier and TypeMethodDescriptionPrepareCallback.replicasMissingMostRecentCommit(TableMetadata metadata) Constructors in org.apache.cassandra.service.paxos.v1 with parameters of type TableMetadataModifierConstructorDescriptionPrepareCallback(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 TableMetadataModifier and TypeMethodDescriptionstatic 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 TableMetadataModifier and TypeMethodDescriptionstatic TableMetadataUtil.metadataFromSSTable(Descriptor desc) Construct table schema from info stored in SSTable's Stats.dbMethods in org.apache.cassandra.tools with parameters of type TableMetadataModifier and TypeMethodDescriptionstatic voidJsonTransformer.keysToJson(ISSTableScanner currentScanner, Stream<DecoratedKey> keys, boolean rawTime, TableMetadata metadata, OutputStream out) static voidJsonTransformer.toJson(ISSTableScanner currentScanner, Stream<UnfilteredRowIterator> partitions, boolean rawTime, TableMetadata metadata, OutputStream out) static voidJsonTransformer.toJsonLines(ISSTableScanner currentScanner, Stream<UnfilteredRowIterator> partitions, boolean rawTime, TableMetadata metadata, OutputStream out) -
Uses of TableMetadata in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport with parameters of type TableMetadataModifier and TypeMethodDescriptionvoidServer.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 TableMetadataModifier and TypeMethodDescriptionstatic voidDiagnosticSnapshotService.duplicateRows(TableMetadata metadata, Iterable<InetAddressAndPort> replicas) static voidDiagnosticSnapshotService.repairedDataMismatch(TableMetadata metadata, Iterable<InetAddressAndPort> replicas) static voidDiagnosticSnapshotService.repairedDataMismatch(TableMetadata metadata, Iterable<InetAddressAndPort> replicas, List<Range<Token>> ranges)