Uses of Class
org.apache.cassandra.db.DecoratedKey
Packages that use DecoratedKey
Package
Description
File transfer
-
Uses of DecoratedKey in org.apache.cassandra.cache
Constructors in org.apache.cassandra.cache with parameters of type DecoratedKey -
Uses of DecoratedKey in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionstatic Map<DecoratedKey,List<Row>> QueryProcessor.executeInternalRawWithNow(long nowInSec, String query, Object... values) A special version of executeInternal that takes the time used as "now" for the query in argument.Methods in org.apache.cassandra.cql3 with parameters of type DecoratedKeyModifier and TypeMethodDescriptionvoidConstants.Adder.execute(DecoratedKey partitionKey, UpdateParameters params) voidConstants.Deleter.execute(DecoratedKey partitionKey, UpdateParameters params) voidConstants.Setter.execute(DecoratedKey partitionKey, UpdateParameters params) voidConstants.Substracter.execute(DecoratedKey partitionKey, UpdateParameters params) voidLists.Appender.execute(DecoratedKey partitionKey, UpdateParameters params) voidLists.Discarder.execute(DecoratedKey partitionKey, UpdateParameters params) voidLists.DiscarderByIndex.execute(DecoratedKey partitionKey, UpdateParameters params) voidLists.Prepender.execute(DecoratedKey partitionKey, UpdateParameters params) voidLists.Setter.execute(DecoratedKey partitionKey, UpdateParameters params) voidLists.SetterByIndex.execute(DecoratedKey partitionKey, UpdateParameters params) voidMaps.DiscarderByKey.execute(DecoratedKey partitionKey, UpdateParameters params) voidMaps.Putter.execute(DecoratedKey partitionKey, UpdateParameters params) voidMaps.Setter.execute(DecoratedKey partitionKey, UpdateParameters params) voidMaps.SetterByKey.execute(DecoratedKey partitionKey, UpdateParameters params) abstract voidOperation.execute(DecoratedKey partitionKey, UpdateParameters params) Execute the operation.voidSets.Adder.execute(DecoratedKey partitionKey, UpdateParameters params) voidSets.Discarder.execute(DecoratedKey partitionKey, UpdateParameters params) voidSets.ElementDiscarder.execute(DecoratedKey partitionKey, UpdateParameters params) voidSets.Setter.execute(DecoratedKey partitionKey, UpdateParameters params) voidUserTypes.DeleterByField.execute(DecoratedKey partitionKey, UpdateParameters params) voidUserTypes.Setter.execute(DecoratedKey partitionKey, UpdateParameters params) voidUserTypes.SetterByField.execute(DecoratedKey partitionKey, UpdateParameters params) static UntypedResultSet.RowUntypedResultSet.Row.fromInternalRow(TableMetadata metadata, DecoratedKey key, Row row) UpdateParameters.getPrefetchedRow(DecoratedKey key, Clustering<?> clustering) Returns the prefetched row with the already performed modifications.Constructor parameters in org.apache.cassandra.cql3 with type arguments of type DecoratedKeyModifierConstructorDescriptionUpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, long nowInSec, int ttl, Map<DecoratedKey, Partition> prefetchedRows) -
Uses of DecoratedKey in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type DecoratedKeyModifier and TypeMethodDescriptionvoidResultSetBuilder.newRow(ProtocolVersion protocolVersion, DecoratedKey partitionKey, Clustering<?> clustering, List<ColumnMetadata> columns) Notifies thisBuilderthat a new row is being processed. -
Uses of DecoratedKey in org.apache.cassandra.cql3.statements
Fields in org.apache.cassandra.cql3.statements declared as DecoratedKeyMethods in org.apache.cassandra.cql3.statements that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionSelectStatement.executeRawInternal(QueryOptions options, ClientState state, long nowInSec) Methods in org.apache.cassandra.cql3.statements with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic ByteBuffer[]SelectStatement.getComponents(TableMetadata metadata, DecoratedKey dk) UpdatesCollector.getPartitionUpdateBuilder(TableMetadata metadata, DecoratedKey dk, ConsistencyLevel consistency) SelectStatement.internalReadForView(DecoratedKey key, long nowInSec) Returns a read command that can be used internally to query all the rows queried by this SELECT for a give key (used for materialized views).Constructors in org.apache.cassandra.cql3.statements with parameters of type DecoratedKeyModifierConstructorDescriptionCQL3CasRequest(TableMetadata metadata, DecoratedKey key, RegularAndStaticColumns conditionColumns, boolean updatesRegularRows, boolean updatesStaticRow) -
Uses of DecoratedKey in org.apache.cassandra.db
Subclasses of DecoratedKey in org.apache.cassandra.dbModifier and TypeClassDescriptionclassclassclassclassFields in org.apache.cassandra.db declared as DecoratedKeyModifier and TypeFieldDescriptionprotected final DecoratedKeySinglePartitionReadCommand.partitionKeyFields in org.apache.cassandra.db with type parameters of type DecoratedKeyMethods in org.apache.cassandra.db that return DecoratedKeyModifier and TypeMethodDescriptionColumnFamilyStore.decorateKey(ByteBuffer key) CounterMutation.key()IMutation.key()Mutation.key()Mutation.PartitionUpdateCollector.key()SinglePartitionReadCommand.partitionKey()SinglePartitionReadQuery.partitionKey()Returns the key of the partition queried by thisReadQueryDecoratedKey.retainable()If this key occupies only part of a larger buffer, allocate a new buffer that is only as large as necessary.Methods in org.apache.cassandra.db that return types with arguments of type DecoratedKeyMethods in org.apache.cassandra.db with parameters of type DecoratedKeyModifier and TypeMethodDescriptionDataRange.clusteringIndexFilter(DecoratedKey key) The clustering index filter to use for the provided key.DataRange.Paging.clusteringIndexFilter(DecoratedKey key) PartitionRangeReadCommand.clusteringIndexFilter(DecoratedKey key) abstract ClusteringIndexFilterReadCommand.clusteringIndexFilter(DecoratedKey key) The clustering index filter this command to use for the provided key.SinglePartitionReadCommand.clusteringIndexFilter(DecoratedKey key) booleanColumnFamilyStore.containsCachedParition(DecoratedKey key) 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.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.voidColumnFamilyStore.forceCompactionForKey(DecoratedKey key) static SinglePartitionReadCommandSinglePartitionReadCommand.fullPartitionRead(TableMetadata metadata, long nowInSec, DecoratedKey key) Creates a new read command that queries a single partition in its entirety.DiskBoundaries.getCorrectDiskForKey(DecoratedKey key) DiskBoundaries.getDisksInBounds(DecoratedKey first, DecoratedKey last) ColumnFamilyStore.getPaxosRepairLowBound(DecoratedKey key) abstract LongPredicateAbstractCompactionController.getPurgeEvaluator(DecoratedKey key) ColumnFamilyStore.getRawCachedPartition(DecoratedKey key) static voidUnfilteredValidation.handleInvalid(TableMetadata metadata, DecoratedKey key, SSTableReader sstable, String invalidContent) voidColumnFamilyStore.invalidateCachedPartition(DecoratedKey key) 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 filtersStorageHook.makeRowIterator(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) StorageHook.makeRowIteratorWithLowerBound(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey partitionKey, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener) static voidUnfilteredValidation.maybeValidateUnfiltered(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey key, SSTableReader sstable) voidStorageHook.reportRead(TableId tableId, DecoratedKey key) 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) default booleanPartitionRangeReadQuery.selectsClustering(DecoratedKey key, Clustering<?> clustering) booleanReadQuery.selectsClustering(DecoratedKey key, Clustering<?> clustering) booleanSinglePartitionReadQuery.Group.selectsClustering(DecoratedKey key, Clustering<?> clustering) default booleanSinglePartitionReadQuery.selectsClustering(DecoratedKey key, Clustering<?> clustering) default booleanPartitionRangeReadQuery.selectsKey(DecoratedKey key) booleanReadQuery.selectsKey(DecoratedKey key) booleanSinglePartitionReadQuery.Group.selectsKey(DecoratedKey key) default booleanSinglePartitionReadQuery.selectsKey(DecoratedKey key) AbstractCompactionController.shadowSources(DecoratedKey key, boolean tombstoneOnly) booleanColumnFamilyStore.shouldIgnoreGcGraceForKey(DecoratedKey dk) static Mutation.SimpleBuilderMutation.simpleBuilder(String keyspaceName, DecoratedKey partitionKey) Creates a new simple mutuation builder.ReadResponse.toDebugString(ReadCommand command, DecoratedKey key) Creates a string of the requested partition in this read response suitable for debugging.static UnfilteredRowIteratorEmptyIterators.unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder) static UnfilteredRowIteratorEmptyIterators.unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder, Row staticRow, DeletionTime partitionDeletion) Method parameters in org.apache.cassandra.db with type arguments of type DecoratedKeyModifier and TypeMethodDescriptionSinglePartitionReadCommand.Group.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter) static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery>SinglePartitionReadQuery.createGroup(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter) Constructors in org.apache.cassandra.db with parameters of type DecoratedKeyModifierConstructorDescriptionMutation(String keyspaceName, DecoratedKey key, com.google.common.collect.ImmutableMap<TableId, PartitionUpdate> modifications, long approxCreatedAtNanos) Mutation(String keyspaceName, DecoratedKey key, com.google.common.collect.ImmutableMap<TableId, PartitionUpdate> modifications, long approxCreatedAtNanos, boolean cdcEnabled) MutationBuilder(String keyspaceName, DecoratedKey key) PartitionUpdateCollector(String keyspaceName, DecoratedKey key) 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 DecoratedKey in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation with parameters of type DecoratedKeyModifier and TypeMethodDescriptionabstract booleanGroupMaker.isNewGroup(DecoratedKey partitionKey, Clustering<?> clustering) Checks if a given row belongs to the same group that the previous row or not. -
Uses of DecoratedKey in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction with parameters of type DecoratedKeyModifier and TypeMethodDescriptionvoidCompactionManager.forceCompactionForKey(ColumnFamilyStore cfStore, DecoratedKey key) CompactionController.getPurgeEvaluator(DecoratedKey key) SSTableSplitter.SplitController.getPurgeEvaluator(DecoratedKey key) CompactionController.shadowSources(DecoratedKey key, boolean tombstoneOnly) Method parameters in org.apache.cassandra.db.compaction with type arguments of type DecoratedKeyModifier and TypeMethodDescriptionvoidCompactionManager.forceCompactionForKeys(ColumnFamilyStore cfStore, Collection<DecoratedKey> keys) -
Uses of DecoratedKey in org.apache.cassandra.db.compaction.unified
Methods in org.apache.cassandra.db.compaction.unified with parameters of type DecoratedKeyModifier and TypeMethodDescriptionprotected booleanShardedCompactionWriter.shouldSwitchWriterInCurrentLocation(DecoratedKey key) protected SSTableWriterShardedCompactionWriter.sstableWriter(Directories.DataDirectory directory, DecoratedKey nextKey) -
Uses of DecoratedKey in org.apache.cassandra.db.compaction.writers
Methods in org.apache.cassandra.db.compaction.writers with parameters of type DecoratedKeyModifier and TypeMethodDescriptionprotected booleanCompactionAwareWriter.maybeSwitchLocation(DecoratedKey key) Switches the file location and writer and returns true if the new key should be placed in a different data directory.protected voidCompactionAwareWriter.maybeSwitchWriter(DecoratedKey key) Switches the writer if necessary, i.e.protected abstract booleanCompactionAwareWriter.shouldSwitchWriterInCurrentLocation(DecoratedKey key) Returns true if the writer should be switched for reasons other than switching to a new data directory (e.g.protected booleanDefaultCompactionWriter.shouldSwitchWriterInCurrentLocation(DecoratedKey key) protected booleanMajorLeveledCompactionWriter.shouldSwitchWriterInCurrentLocation(DecoratedKey key) protected booleanMaxSSTableSizeWriter.shouldSwitchWriterInCurrentLocation(DecoratedKey key) protected booleanSplittingSizeTieredCompactionWriter.shouldSwitchWriterInCurrentLocation(DecoratedKey key) protected SSTableWriterCompactionAwareWriter.sstableWriter(Directories.DataDirectory directory, DecoratedKey nextKey) protected voidCompactionAwareWriter.switchCompactionWriter(Directories.DataDirectory directory, DecoratedKey nextKey) Implementations of this method should finish the current sstable writer and start writing to this directory.voidMajorLeveledCompactionWriter.switchCompactionWriter(Directories.DataDirectory location, DecoratedKey nextKey) -
Uses of DecoratedKey in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter with parameters of type DecoratedKeyModifier and TypeMethodDescriptionprotected abstract voidDataLimits.Counter.applyToPartition(DecoratedKey partitionKey, Row staticRow) 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) booleanRowFilter.partitionKeyRestrictionsAreSatisfiedBy(DecoratedKey key, AbstractType<?> keyValidator) Returns true if all of the expressions within this filter that apply to the partition key are satisfied by the given key, false otherwise.Constructors in org.apache.cassandra.db.filter with parameters of type DecoratedKeyModifierConstructorDescriptionTombstoneOverwhelmingException(int numTombstones, String query, TableMetadata metadata, DecoratedKey lastPartitionKey, ClusteringPrefix<?> lastClustering) -
Uses of DecoratedKey in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic com.google.common.base.Function<View,Iterable<SSTableReader>> View.select(SSTableSet sstableSet, DecoratedKey key) -
Uses of DecoratedKey in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable with parameters of type DecoratedKeyModifier and TypeMethodDescriptionShardedSkipListMemtable.rowIterator(DecoratedKey key) ShardedSkipListMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) SkipListMemtable.rowIterator(DecoratedKey key) SkipListMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) TrieMemtable.rowIterator(DecoratedKey key) TrieMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) -
Uses of DecoratedKey in org.apache.cassandra.db.partitions
Fields in org.apache.cassandra.db.partitions declared as DecoratedKeyModifier and TypeFieldDescriptionprotected final DecoratedKeyAbstractBTreePartition.partitionKeyMethods in org.apache.cassandra.db.partitions that return DecoratedKeyModifier and TypeMethodDescriptionAbstractBTreePartition.partitionKey()AtomicBTreePartition.partitionKey()Partition.partitionKey()PartitionUpdate.Builder.partitionKey()Methods in org.apache.cassandra.db.partitions with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic PartitionUpdatePartitionUpdate.emptyUpdate(TableMetadata metadata, DecoratedKey key) Creates a empty immutable partition update.static PartitionUpdatePartitionUpdate.fullPartitionDelete(TableMetadata metadata, DecoratedKey key, long timestamp, long nowInSec) Creates an immutable partition update that entirely deletes a given partition.UnfilteredPartitionIterators.MergeListener.getRowMergeListener(DecoratedKey partitionKey, List<UnfilteredRowIterator> versions) static booleanPartitionUpdate.PartitionUpdateSerializer.isEmpty(ByteBuffer in, DeserializationHelper.Flag flag, DecoratedKey key) protected voidPurgeFunction.onEmptyPartitionPostPurge(DecoratedKey partitionKey) protected voidPurgeFunction.onNewPartition(DecoratedKey partitionKey) 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 DecoratedKeyModifierConstructorDescriptionprotectedAbstractBTreePartition(DecoratedKey partitionKey) AtomicBTreePartition(TableMetadataRef metadata, DecoratedKey partitionKey, MemtableAllocator allocator) 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 DecoratedKey in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as DecoratedKeyModifier and TypeFieldDescriptionfinal DecoratedKeyUnfilteredRowIteratorSerializer.Header.keyprotected final DecoratedKeyAbstractUnfilteredRowIterator.partitionKeyMethods in org.apache.cassandra.db.rows that return DecoratedKeyModifier and TypeMethodDescriptionAbstractUnfilteredRowIterator.partitionKey()BaseRowIterator.partitionKey()The partition key of the partition this in an iterator over.LazilyInitializedUnfilteredRowIterator.partitionKey()default DecoratedKeyWrappingUnfilteredRowIterator.partitionKey()Methods in org.apache.cassandra.db.rows with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic UnfilteredRowIteratorUnfilteredRowIterators.noRowsIterator(TableMetadata metadata, DecoratedKey partitionKey, Row staticRow, DeletionTime partitionDeletion, boolean isReverseOrder) Returns an empty unfiltered iterator for a given partition.default UnfilteredRowIteratorUnfilteredSource.rowIterator(DecoratedKey key) UnfilteredSource.rowIterator(DecoratedKey key, Slices slices, ColumnFilter columnFilter, boolean reversed, SSTableReadsListener listener) Returns a row iterator for the given partition, applying the specified row and column filters.static UnfilteredRowIteratorUnfilteredRowIterators.singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats) Constructors in org.apache.cassandra.db.rows with parameters of type DecoratedKeyModifierConstructorDescriptionprotectedAbstractUnfilteredRowIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats stats) LazilyInitializedUnfilteredRowIterator(DecoratedKey partitionKey) RowAndDeletionMergeIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, ColumnFilter selection, Row staticRow, boolean isReversed, EncodingStats stats, Iterator<Row> rows, Iterator<RangeTombstone> ranges, boolean removeShadowedData) UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener) UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, Slices slices, boolean isReverseOrder, ColumnFilter selectedColumns, SSTableReadsListener listener) -
Uses of DecoratedKey in org.apache.cassandra.db.streaming
Fields in org.apache.cassandra.db.streaming declared as DecoratedKeyModifier and TypeFieldDescriptionfinal DecoratedKeyCassandraStreamHeader.firstKeyprotected DecoratedKeyCassandraStreamReader.StreamDeserializer.keyMethods in org.apache.cassandra.db.streaming that return DecoratedKeyMethods in org.apache.cassandra.db.streaming with parameters of type DecoratedKeyModifier and TypeMethodDescriptionCassandraStreamHeader.Builder.withFirstKey(DecoratedKey firstKey) -
Uses of DecoratedKey in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return DecoratedKeyModifier and TypeMethodDescriptionprotected DecoratedKeyTransformation.applyToPartitionKey(DecoratedKey key) Applied to the partition key of any rows/unfiltered iterator we are applied toBaseRows.partitionKey()Methods in org.apache.cassandra.db.transform with parameters of type DecoratedKeyModifier and TypeMethodDescriptionprotected DecoratedKeyTransformation.applyToPartitionKey(DecoratedKey key) Applied to the partition key of any rows/unfiltered iterator we are applied to -
Uses of DecoratedKey in org.apache.cassandra.db.view
Methods in org.apache.cassandra.db.view with parameters of type DecoratedKeyModifier and TypeMethodDescriptionbooleanView.matchesViewFilter(DecoratedKey partitionKey, Row baseRow, long nowInSec) Whether a given base row matches the view filter (and thus if is should have a corresponding entry).booleanView.mayBeAffectedBy(DecoratedKey partitionKey, Row update) Whether the view might be affected by the provided update.Constructors in org.apache.cassandra.db.view with parameters of type DecoratedKeyModifierConstructorDescriptionViewUpdateGenerator(View view, DecoratedKey basePartitionKey, long nowInSec) Creates a newViewUpdateBuilder. -
Uses of DecoratedKey in org.apache.cassandra.db.virtual
Fields in org.apache.cassandra.db.virtual with type parameters of type DecoratedKeyModifier and TypeFieldDescriptionprotected final NavigableMap<DecoratedKey,AbstractVirtualTable.Partition> AbstractVirtualTable.AbstractDataSet.partitionsMethods in org.apache.cassandra.db.virtual that return DecoratedKeyMethods in org.apache.cassandra.db.virtual with parameters of type DecoratedKeyModifier and TypeMethodDescriptionAbstractVirtualTable.data(DecoratedKey partitionKey) Provide aAbstractVirtualTable.DataSetthat is potentially restricted to the provided partition - but is allowed to contain other partitions.InternodeInboundTable.data(DecoratedKey partitionKey) InternodeOutboundTable.data(DecoratedKey partitionKey) SettingsTable.data(DecoratedKey partitionKey) StreamingVirtualTable.data(DecoratedKey partitionKey) AbstractMutableVirtualTable.ColumnValues.from(TableMetadata metadata, DecoratedKey partitionKey) Returns the set of column values corresponding to the specified partition key.AbstractVirtualTable.AbstractDataSet.getPartition(DecoratedKey key) AbstractVirtualTable.DataSet.getPartition(DecoratedKey partitionKey) AbstractVirtualTable.select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter) VirtualTable.select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter) Selects the rows from a single partition.Constructors in org.apache.cassandra.db.virtual with parameters of type DecoratedKeyModifierConstructorDescriptionVirtualMutation(String keyspaceName, DecoratedKey partitionKey, com.google.common.collect.ImmutableMap<TableId, PartitionUpdate> modifications) Constructor parameters in org.apache.cassandra.db.virtual with type arguments of type DecoratedKeyModifierConstructorDescriptionprotectedSimpleDataSet(TableMetadata metadata, Comparator<DecoratedKey> comparator) -
Uses of DecoratedKey in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht that return DecoratedKeyModifier and TypeMethodDescriptionByteOrderedPartitioner.decorateKey(ByteBuffer key) IPartitioner.decorateKey(ByteBuffer key) Transform key to object representation of the on-disk format.LocalPartitioner.decorateKey(ByteBuffer key) Murmur3Partitioner.decorateKey(ByteBuffer key) OrderPreservingPartitioner.decorateKey(ByteBuffer key) RandomPartitioner.decorateKey(ByteBuffer key) -
Uses of DecoratedKey in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type DecoratedKeyModifier and TypeMethodDescriptionIndex.Group.indexerFor(Predicate<Index> indexSelector, DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) Creates an newIndexerobject for updates to a given partition.Index.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) Creates an newIndexerobject for updates to a given partition.SingletonIndexGroup.indexerFor(Predicate<Index> indexSelector, DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) voidSecondaryIndexManager.indexPartition(DecoratedKey key, Set<Index> indexes, int pageSize) voidSecondaryIndexManager.indexPartition(DecoratedKey key, Set<Index> indexes, int pageSize, RegularAndStaticColumns columns) When building an index against existing data in sstables, add the given partition to the indexSecondaryIndexManager.newCleanupTransaction(DecoratedKey key, RegularAndStaticColumns regularAndStaticColumns, long nowInSec) Transaction for use when removing partitions during cleanupSecondaryIndexManager.newCompactionTransaction(DecoratedKey key, RegularAndStaticColumns regularAndStaticColumns, int versions, long nowInSec) Transaction for use when merging rows during compaction -
Uses of DecoratedKey in org.apache.cassandra.index.internal
Fields in org.apache.cassandra.index.internal declared as DecoratedKeyMethods in org.apache.cassandra.index.internal with parameters of type DecoratedKeyModifier and TypeMethodDescriptionabstract IndexEntryCassandraIndex.decodeEntry(DecoratedKey indexedValue, Row indexEntry) Used at search time to convert a row in the index table into a simple struct containing the values required to retrieve the corresponding row from the base table.voidCassandraIndex.deleteStaleEntry(DecoratedKey indexKey, Clustering<?> indexClustering, DeletionTime deletion, WriteContext ctx) Specific to internal indexes, this is called by a searcher when it encounters a stale entry in the indexCassandraIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) protected abstract UnfilteredPartitionIteratorCassandraIndexSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) Constructors in org.apache.cassandra.index.internal with parameters of type DecoratedKeyModifierConstructorDescriptionIndexEntry(DecoratedKey indexValue, Clustering<?> indexClustering, long timestamp, ByteBuffer indexedKey, Clustering<?> indexedEntryClustering) -
Uses of DecoratedKey in org.apache.cassandra.index.internal.composites
Methods in org.apache.cassandra.index.internal.composites with parameters of type DecoratedKeyModifier and TypeMethodDescriptionClusteringColumnIndex.decodeEntry(DecoratedKey indexedValue, Row indexEntry) CollectionKeyIndexBase.decodeEntry(DecoratedKey indexedValue, Row indexEntry) CollectionValueIndex.decodeEntry(DecoratedKey indexedValue, Row indexEntry) PartitionKeyIndex.decodeEntry(DecoratedKey indexedValue, Row indexEntry) RegularColumnIndex.decodeEntry(DecoratedKey indexedValue, Row indexEntry) protected UnfilteredPartitionIteratorCompositesSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) -
Uses of DecoratedKey in org.apache.cassandra.index.internal.keys
Methods in org.apache.cassandra.index.internal.keys with parameters of type DecoratedKeyModifier and TypeMethodDescriptionKeysIndex.decodeEntry(DecoratedKey indexedValue, Row indexEntry) protected UnfilteredPartitionIteratorKeysSearcher.queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) -
Uses of DecoratedKey in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai with parameters of type DecoratedKeyModifier and TypeMethodDescriptionStorageAttachedIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext writeContext, IndexTransaction.Type transactionType, Memtable memtable) StorageAttachedIndexGroup.indexerFor(Predicate<Index> indexSelector, DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) booleanStorageAttachedIndex.validateTermSize(DecoratedKey key, ByteBuffer term, boolean isClientMutation, ClientState state) voidStorageAttachedIndex.validateTermSizeForRow(DecoratedKey key, Row row, boolean isClientMutation, ClientState state) Validate maximum term size for given row -
Uses of DecoratedKey in org.apache.cassandra.index.sai.disk
Methods in org.apache.cassandra.index.sai.disk with parameters of type DecoratedKeyModifier and TypeMethodDescriptiondefault voidPerSSTableIndexWriter.startPartition(DecoratedKey decoratedKey) voidStorageAttachedIndexWriter.startPartition(DecoratedKey key, long keyPosition, long keyPositionForSASI) -
Uses of DecoratedKey in org.apache.cassandra.index.sai.disk.v1
Methods in org.apache.cassandra.index.sai.disk.v1 that return DecoratedKeyModifier and TypeMethodDescriptionprotected DecoratedKeySkinnyPrimaryKeyMap.readPartitionKey(long sstableRowId) Methods in org.apache.cassandra.index.sai.disk.v1 with parameters of type DecoratedKeyModifier and TypeMethodDescriptionvoidSSTableComponentsWriter.startPartition(DecoratedKey partitionKey) -
Uses of DecoratedKey in org.apache.cassandra.index.sai.memory
Methods in org.apache.cassandra.index.sai.memory with parameters of type DecoratedKeyModifier and TypeMethodDescriptionabstract longMemoryIndex.add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) longTrieMemoryIndex.add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) Adds an index value to the in-memory indexlongVectorMemoryIndex.add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) longMemtableIndex.index(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) longMemtableIndexManager.index(DecoratedKey key, Row row, Memtable mt) abstract longMemoryIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) longMemtableIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) longMemtableIndexManager.update(DecoratedKey key, Row oldRow, Row newRow, Memtable memtable) longTrieMemoryIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) longVectorMemoryIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) -
Uses of DecoratedKey in org.apache.cassandra.index.sai.plan
Methods in org.apache.cassandra.index.sai.plan with parameters of type DecoratedKeyModifier and TypeMethodDescriptionbooleanFilterTree.isSatisfiedBy(DecoratedKey key, Row row, Row staticRow) -
Uses of DecoratedKey in org.apache.cassandra.index.sai.utils
Fields in org.apache.cassandra.index.sai.utils declared as DecoratedKeyMethods in org.apache.cassandra.index.sai.utils that return DecoratedKeyModifier and TypeMethodDescriptionPrimaryKey.partitionKey()Returns theDecoratedKeyrepresenting the partition key of thePrimaryKey.PrimaryKey.Factory.partitionKeyFromComparableBytes(ByteSource byteSource) Create aDecoratedKeyfrom aByteSource.Methods in org.apache.cassandra.index.sai.utils with parameters of type DecoratedKeyModifier and TypeMethodDescriptionPrimaryKey.Factory.create(DecoratedKey partitionKey) Create aPrimaryKeyfor tables without clustering columnsPrimaryKey.Factory.create(DecoratedKey partitionKey, Clustering<?> clustering) Creates aPrimaryKeythat is fully represented by partition key and clustering.IndexTermType.valueOf(DecoratedKey key, Row row, long nowInSecs) Returns the cell value from theDecoratedKeyorRowfor theIndexTermTypebased on the kind of column thisIndexTermTypeis based on.Constructors in org.apache.cassandra.index.sai.utils with parameters of type DecoratedKeyModifierConstructorDescriptionPartitionInfo(DecoratedKey key, Row staticRow) PartitionInfo(DecoratedKey key, Row staticRow, DeletionTime partitionDeletion, EncodingStats encodingStats) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type DecoratedKeyModifier and TypeMethodDescriptionSASIIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext context, IndexTransaction.Type transactionType, Memtable memtable) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi.conf
Methods in org.apache.cassandra.index.sasi.conf with parameters of type DecoratedKey -
Uses of DecoratedKey in org.apache.cassandra.index.sasi.disk
Fields in org.apache.cassandra.index.sasi.disk with type parameters of type DecoratedKeyModifier and TypeFieldDescriptionprotected final com.google.common.base.Function<Long,DecoratedKey> OnDiskIndex.keyFetcherMethods in org.apache.cassandra.index.sasi.disk that return types with arguments of type DecoratedKeyMethods in org.apache.cassandra.index.sasi.disk with parameters of type DecoratedKeyModifier and TypeMethodDescriptionOnDiskIndexBuilder.add(ByteBuffer term, DecoratedKey key, long keyPosition) voidPerSSTableIndexWriter.Index.add(ByteBuffer term, DecoratedKey key, long keyPosition) voidPerSSTableIndexWriter.startPartition(DecoratedKey key, long keyPosition, long KeyPositionForSASI) Method parameters in org.apache.cassandra.index.sasi.disk with type arguments of type DecoratedKeyModifier and TypeMethodDescriptionTokenTree.get(long searchToken, com.google.common.base.Function<Long, DecoratedKey> keyFetcher) static TokenTree.OnDiskTokenTokenTree.OnDiskToken.getTokenAt(MappedBuffer buffer, int idx, short leafSize, com.google.common.base.Function<Long, DecoratedKey> keyFetcher) TokenTree.iterator(com.google.common.base.Function<Long, DecoratedKey> keyFetcher) Constructor parameters in org.apache.cassandra.index.sasi.disk with type arguments of type DecoratedKeyModifierConstructorDescriptionOnDiskIndex(File index, AbstractType<?> cmp, com.google.common.base.Function<Long, DecoratedKey> keyReader) OnDiskToken(MappedBuffer buffer, long position, short leafSize, com.google.common.base.Function<Long, DecoratedKey> keyFetcher) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi.memory
Methods in org.apache.cassandra.index.sasi.memory that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionTrieMemIndex.ConcurrentPrefixTrie.putIfAbsent(String value, ConcurrentSkipListSet<DecoratedKey> newKeys) TrieMemIndex.ConcurrentSuffixTrie.putIfAbsent(String value, ConcurrentSkipListSet<DecoratedKey> newKeys) TrieMemIndex.ConcurrentPrefixTrie.search(Expression.Op operator, String value) TrieMemIndex.ConcurrentSuffixTrie.search(Expression.Op operator, String value) Methods in org.apache.cassandra.index.sasi.memory with parameters of type DecoratedKeyModifier and TypeMethodDescriptionabstract longMemIndex.add(DecoratedKey key, ByteBuffer value) longSkipListMemIndex.add(DecoratedKey key, ByteBuffer value) longTrieMemIndex.add(DecoratedKey key, ByteBuffer value) longIndexMemtable.index(DecoratedKey key, ByteBuffer value) Method parameters in org.apache.cassandra.index.sasi.memory with type arguments of type DecoratedKeyModifier and TypeMethodDescriptionTrieMemIndex.ConcurrentPrefixTrie.putIfAbsent(String value, ConcurrentSkipListSet<DecoratedKey> newKeys) TrieMemIndex.ConcurrentSuffixTrie.putIfAbsent(String value, ConcurrentSkipListSet<DecoratedKey> newKeys) Constructor parameters in org.apache.cassandra.index.sasi.memory with type arguments of type DecoratedKeyModifierConstructorDescriptionKeyRangeIterator(ConcurrentSkipListSet<DecoratedKey> keys, int size) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan with parameters of type DecoratedKeyModifier and TypeMethodDescriptionQueryController.getPartition(DecoratedKey key, ReadExecutionController executionController) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as DecoratedKeyMethods in org.apache.cassandra.io.sstable that return DecoratedKeyModifier and TypeMethodDescriptionprotected DecoratedKeyKeyIterator.computeNext()SSTable.decorateKey(ByteBuffer key) abstract DecoratedKeySSTable.getFirst()SSTableZeroCopyWriter.getFirst()abstract DecoratedKeySSTable.getLast()SSTableZeroCopyWriter.getLast()ReducingKeyIterator.next()AbstractSSTableIterator.partitionKey()SSTableIdentityIterator.partitionKey()Methods in org.apache.cassandra.io.sstable with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic SSTableIdentityIteratorSSTableIdentityIterator.create(SSTableReader sstable, FileDataInput dfile, long dataPosition, DecoratedKey key, boolean tombstoneOnly) static SSTableIdentityIteratorSSTableIdentityIterator.create(SSTableReader sstable, RandomAccessReader file, DecoratedKey key) voidSSTableFlushObserver.startPartition(DecoratedKey key, long keyPosition, long keyPositionForSASI) Called when a new partition in being written to the sstable, but before any cells are processed (seeSSTableFlushObserver.nextUnfilteredCluster(Unfiltered)).Constructors in org.apache.cassandra.io.sstable with parameters of type DecoratedKeyModifierConstructorDescriptionprotectedAbstractSSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RIE indexEntry, Slices slices, ColumnFilter columnFilter, FileHandle ifile) SSTableIdentityIterator(SSTableReader sstable, DecoratedKey key, DeletionTime partitionLevelDeletion, String filename, SSTableSimpleIterator iterator) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as DecoratedKeyModifier and TypeFieldDescriptionprotected DecoratedKeySSTableScanner.BaseKeyScanningIterator.currentKeyprotected final DecoratedKeySSTableReader.firstprotected DecoratedKeySSTableWriter.firstprotected final DecoratedKeySSTableReader.lastprotected DecoratedKeySSTableWriter.lastMethods in org.apache.cassandra.io.sstable.format that return DecoratedKeyModifier and TypeMethodDescriptionabstract DecoratedKeySSTableReader.firstKeyBeyond(PartitionPosition token) Finds and returns the first key beyond a given token in this SSTable or null if no such key exists.SSTableReader.Builder.getFirst()SSTableReader.getFirst()SSTableWriter.getFirst()SSTableReader.Builder.getLast()SSTableReader.getLast()SSTableWriter.getLast()abstract DecoratedKeySSTableReader.keyAtPositionFromSecondaryIndex(long keyPositionFromSecondaryIndex) Reads the key stored at the position saved in SASI.Methods in org.apache.cassandra.io.sstable.format that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionabstract Iterable<DecoratedKey>SSTableReader.getKeySamples(Range<Token> range) Returns sample keys for the provided token range.SSTableFormat.SSTableReaderFactory.readKeyRange(Descriptor descriptor, IPartitioner partitioner) Retrieves a key range for the given sstable at the lowest cost - that is, without opening all sstables files if possible.SSTableFormat.SSTableReaderFactory.readKeyRange(Descriptor descriptor, IPartitioner partitioner) Retrieves a key range for the given sstable at the lowest cost - that is, without opening all sstables files if possible.Methods in org.apache.cassandra.io.sstable.format with parameters of type DecoratedKeyModifier and TypeMethodDescriptionbooleanSortedTableVerifier.RangeOwnHelper.check(DecoratedKey key) check if the given key is contained in any of the given rangesabstract SSTableReaderSSTableReader.cloneWithNewStart(DecoratedKey newStart) abstract SSTableReaderSSTableReader.cloneWithRestoredStart(DecoratedKey restoredStart) protected abstract AbstractRowIndexEntrySortedTableWriter.createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult) SortedTableVerifier.VerifyController.getPurgeEvaluator(DecoratedKey key) protected abstract UnfilteredRowIteratorSSTableScanner.BaseKeyScanningIterator.getRowIterator(E indexEntry, DecoratedKey key) protected StringSortedTableScrubber.keyString(DecoratedKey key) abstract booleanSSTableReader.mayContainAssumingKeyIsInRange(DecoratedKey key) The method verifies whether the sstable may contain the provided key.booleanSSTableReaderWithFilter.mayContainAssumingKeyIsInRange(DecoratedKey key) protected voidSortedTableWriter.onStartPartition(DecoratedKey key) SSTableReader.Builder.setFirst(DecoratedKey first) SSTableReader.Builder.setLast(DecoratedKey last) SSTableReader.simpleIterator(FileDataInput file, DecoratedKey key, long dataPosition, boolean tombstoneOnly) voidSortedTablePartitionWriter.start(DecoratedKey key, DeletionTime partitionLevelDeletion) protected voidSortedTableScrubber.throwIfCannotContinue(DecoratedKey key, Throwable th) protected booleanSortedTableScrubber.tryAppend(DecoratedKey prevKey, DecoratedKey key, SSTableRewriter writer) voidSSTableReader.trySkipFileCacheBefore(DecoratedKey key) voidSortedTableVerifier.RangeOwnHelper.validate(DecoratedKey key) check if the given key is contained in any of the given rangesprotected abstract voidSortedTableVerifier.verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.format.big
Fields in org.apache.cassandra.io.sstable.format.big declared as DecoratedKeyModifier and TypeFieldDescriptionfinal DecoratedKeyIndexSummaryComponent.firstfinal DecoratedKeyIndexSummaryComponent.lastMethods in org.apache.cassandra.io.sstable.format.big that return DecoratedKeyModifier and TypeMethodDescriptionBigTableReader.firstKeyBeyond(PartitionPosition token) Finds and returns the first key beyond a given token in this SSTable or null if no such key exists.BigTableReader.keyAtPositionFromSecondaryIndex(long keyPositionFromSecondaryIndex) Methods in org.apache.cassandra.io.sstable.format.big that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionBigTableReader.getKeySamples(Range<Token> range) static Pair<DecoratedKey,DecoratedKey> IndexSummaryComponent.loadFirstAndLastKey(File summaryFile, IPartitioner partitioner) static Pair<DecoratedKey,DecoratedKey> IndexSummaryComponent.loadFirstAndLastKey(File summaryFile, IPartitioner partitioner) Methods in org.apache.cassandra.io.sstable.format.big with parameters of type DecoratedKeyModifier and TypeMethodDescriptionvoidBigTableWriter.IndexWriter.append(DecoratedKey key, RowIndexEntry indexEntry, long dataEnd, ByteBuffer indexInfo) BigTableReader.cloneWithNewStart(DecoratedKey newStart) BigTableReader.cloneWithRestoredStart(DecoratedKey restoredStart) protected RowIndexEntryBigTableWriter.createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult) BigTableReader.getLowerBoundPrefixFromCache(DecoratedKey partitionKey, boolean isReversed) protected UnfilteredRowIteratorBigTableScanner.BigScanningIterator.getRowIterator(RowIndexEntry rowIndexEntry, DecoratedKey key) protected voidBigTableWriter.onStartPartition(DecoratedKey key) BigTableReader.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) BigTableReader.rowIterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed) protected voidBigTableScrubber.throwIfCannotContinue(DecoratedKey key, Throwable th) protected voidBigTableVerifier.verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator) Constructors in org.apache.cassandra.io.sstable.format.big with parameters of type DecoratedKeyModifierConstructorDescriptionIndexSummaryComponent(IndexSummary indexSummary, DecoratedKey first, DecoratedKey last) SSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columns, FileHandle ifile) SSTableReversedIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columns, FileHandle ifile) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.format.bti
Methods in org.apache.cassandra.io.sstable.format.bti that return DecoratedKeyModifier and TypeMethodDescriptionPartitionIndex.firstKey()BtiTableReader.firstKeyBeyond(PartitionPosition token) BtiTableReader.keyAtPositionFromSecondaryIndex(long keyPositionFromSecondaryIndex) PartitionIndex.lastKey()Methods in org.apache.cassandra.io.sstable.format.bti that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionBtiTableReader.getKeySamples(Range<Token> range) static Pair<DecoratedKey,DecoratedKey> PartitionIndex.readFirstAndLastKey(File file, IPartitioner partitioner) static Pair<DecoratedKey,DecoratedKey> PartitionIndex.readFirstAndLastKey(File file, IPartitioner partitioner) Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type DecoratedKeyModifier and TypeMethodDescriptionlongBtiTableWriter.IndexWriter.append(DecoratedKey key, AbstractRowIndexEntry indexEntry) BtiTableReader.cloneWithNewStart(DecoratedKey newStart) BtiTableReader.cloneWithRestoredStart(DecoratedKey restoredStart) protected org.apache.cassandra.io.sstable.format.bti.TrieIndexEntryBtiTableWriter.createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult) longPartitionIndex.Reader.exactCandidate(DecoratedKey key) Finds a candidate for an exact key search.protected UnfilteredRowIteratorBtiTableScanner.BtiScanningIterator.getRowIterator(org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry indexEntry, DecoratedKey key) BtiTableReader.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) BtiTableReader.rowIterator(FileDataInput dataFileInput, DecoratedKey key, org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed) protected voidBtiTableScrubber.throwIfCannotContinue(DecoratedKey key, Throwable th) protected voidBtiTableVerifier.verifyPartition(DecoratedKey key, UnfilteredRowIterator iterator) Constructors in org.apache.cassandra.io.sstable.format.bti with parameters of type DecoratedKeyModifierConstructorDescriptionPartitionIndex(FileHandle fh, long trieRoot, long keyCount, DecoratedKey first, DecoratedKey last) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.indexsummary
Fields in org.apache.cassandra.io.sstable.indexsummary declared as DecoratedKeyMethods in org.apache.cassandra.io.sstable.indexsummary that return types with arguments of type DecoratedKeyModifier and TypeMethodDescriptionIndexSummary.IndexSummarySerializer.deserializeFirstLastKey(DataInputPlus.DataInputStreamPlus in, IPartitioner partitioner) Deserializes the first and last key stored in the summaryIndexSummary.IndexSummarySerializer.deserializeFirstLastKey(DataInputPlus.DataInputStreamPlus in, IPartitioner partitioner) Deserializes the first and last key stored in the summaryMethods in org.apache.cassandra.io.sstable.indexsummary with parameters of type DecoratedKeyModifier and TypeMethodDescriptionIndexSummaryBuilder.maybeAddEntry(DecoratedKey decoratedKey, long indexStart) IndexSummaryBuilder.maybeAddEntry(DecoratedKey decoratedKey, long indexStart, long indexEnd, long dataEnd) Constructors in org.apache.cassandra.io.sstable.indexsummary with parameters of type DecoratedKeyModifierConstructorDescriptionReadableBoundary(DecoratedKey lastKey, long indexLength, long dataLength, int summaryCount, long entriesLength) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.keycache
Methods in org.apache.cassandra.io.sstable.keycache with parameters of type DecoratedKeyModifier and TypeMethodDescriptiondefault voidKeyCacheSupport.cacheKey(DecoratedKey key, AbstractRowIndexEntry info) Caches a key only if cache is available.default AbstractRowIndexEntryKeyCacheSupport.getCachedPosition(DecoratedKey key, boolean updateStats) Will return null if key is not found or cache is not available.default KeyCacheKeyKeyCacheSupport.getCacheKey(DecoratedKey key) KeyCacheSupport.getLowerBoundPrefixFromCache(DecoratedKey partitionKey, boolean isReversed) Should quickly get a lower bound prefix from cache only if everything is already availabe in memory and does not need to be loaded from disk. -
Uses of DecoratedKey in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return DecoratedKeyMethods in org.apache.cassandra.locator with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic ReplicaPlan.ForPaxosWriteReplicaPlans.forPaxos(Keyspace keyspace, DecoratedKey key, ConsistencyLevel consistencyForPaxos) Construct the plan for a paxos round - NOT the write or read consistency level for either the write or comparison, but for the paxos linearisation agreement. -
Uses of DecoratedKey in org.apache.cassandra.metrics
Fields in org.apache.cassandra.metrics declared as DecoratedKeyMethods in org.apache.cassandra.metrics with parameters of type DecoratedKeyModifier and TypeMethodDescriptionvoidTopPartitionTracker.TopHolder.track(DecoratedKey key, long value) voidTopPartitionTracker.Collector.trackPartitionSize(DecoratedKey key, long size) voidTopPartitionTracker.Collector.trackTombstoneCount(DecoratedKey key, long count) Constructors in org.apache.cassandra.metrics with parameters of type DecoratedKey -
Uses of DecoratedKey in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return DecoratedKeyModifier and TypeMethodDescriptionStorageService.getKeyFromPartition(String keyspaceName, String table, String partitionKey) Methods in org.apache.cassandra.service with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic RowIteratorStorageProxy.cas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime) Apply @param updates if and only if the current values in the row for @param key match the provided @param conditions.static RowIteratorStorageProxy.legacyCas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime) -
Uses of DecoratedKey in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type DecoratedKeyModifier and TypeMethodDescriptionprotected booleanPartitionRangeQueryPager.isPreviouslyReturnedPartition(DecoratedKey key) protected booleanSinglePartitionPager.isPreviouslyReturnedPartition(DecoratedKey key) protected voidPartitionRangeQueryPager.recordLast(DecoratedKey key, Row last) protected voidSinglePartitionPager.recordLast(DecoratedKey key, Row last) Constructors in org.apache.cassandra.service.pager with parameters of type DecoratedKeyModifierConstructorDescriptionPartitionRangeQueryPager(PartitionRangeReadQuery query, ProtocolVersion protocolVersion, DecoratedKey lastReturnedKey, PagingState.RowMark lastReturnedRow, int remaining, int remainingInPartition) -
Uses of DecoratedKey in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos that return DecoratedKeyMethods in org.apache.cassandra.service.paxos with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic RowIteratorPaxos.cas(DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForConsensus, ConsistencyLevel consistencyForCommit, ClientState clientState) Apply @param updates if and only if the current values in the row for @param key match the provided @param conditions.static RowIteratorPaxos.cas(DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForConsensus, ConsistencyLevel consistencyForCommit, ClientState clientState, long proposeDeadline, long commitDeadline) 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) Constructors in org.apache.cassandra.service.paxos with parameters of type DecoratedKeyModifierConstructorDescriptionAbstractPaxosRepair(DecoratedKey partitionKey, Ballot incompleteBallot) Key(DecoratedKey partitionKey, TableMetadata metadata) -
Uses of DecoratedKey in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted that return DecoratedKeyMethods in org.apache.cassandra.service.paxos.uncommitted with parameters of type DecoratedKeyModifier and TypeMethodDescriptionstatic Commit.CommittedPaxosRows.getCommitted(TableMetadata metadata, DecoratedKey partitionKey, Row row, long purgeBefore, long overrideTtlSeconds) PaxosUncommittedIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) Constructors in org.apache.cassandra.service.paxos.uncommitted with parameters of type DecoratedKeyModifierConstructorDescriptionPaxosKeyState(TableId tableId, DecoratedKey key, Ballot ballot, boolean committed) -
Uses of DecoratedKey in org.apache.cassandra.service.paxos.v1
Constructors in org.apache.cassandra.service.paxos.v1 with parameters of type DecoratedKeyModifierConstructorDescriptionPrepareCallback(DecoratedKey key, TableMetadata metadata, int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime) -
Uses of DecoratedKey in org.apache.cassandra.service.reads
Methods in org.apache.cassandra.service.reads that return DecoratedKey -
Uses of DecoratedKey in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type DecoratedKeyModifier and TypeMethodDescriptionPartitionIteratorMergeListener.getRowMergeListener(DecoratedKey partitionKey, List<UnfilteredRowIterator> versions) voidBlockingReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) voidNoopReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) voidReadOnlyReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) voidReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) Repairs a partition _after_ receiving data responses.Constructors in org.apache.cassandra.service.reads.repair with parameters of type DecoratedKeyModifierConstructorDescriptionBlockingPartitionRepair(DecoratedKey key, Map<Replica, Mutation> repairs, ReplicaPlan.ForWrite writePlan) RowIteratorMergeListener(DecoratedKey partitionKey, RegularAndStaticColumns columns, boolean isReversed, ReplicaPlan.ForRead<E, ?> readPlan, ReadCommand command, ReadRepair<E, ?> readRepair) -
Uses of DecoratedKey in org.apache.cassandra.streaming
Constructors in org.apache.cassandra.streaming with parameters of type DecoratedKeyModifierConstructorDescriptionStreamReceivedOutOfTokenRangeException(Collection<Range<Token>> ownedRanges, DecoratedKey key, String filename) -
Uses of DecoratedKey in org.apache.cassandra.tools
Method parameters in org.apache.cassandra.tools with type arguments of type DecoratedKeyModifier and TypeMethodDescriptionstatic voidJsonTransformer.keysToJson(ISSTableScanner currentScanner, Stream<DecoratedKey> keys, boolean rawTime, TableMetadata metadata, OutputStream out) -
Uses of DecoratedKey in org.apache.cassandra.utils
Method parameters in org.apache.cassandra.utils with type arguments of type DecoratedKeyModifier and TypeMethodDescriptionstatic voidFBUtilities.sortSampledKeys(List<DecoratedKey> keys, Range<Token> range) -
Uses of DecoratedKey in org.apache.cassandra.utils.memory
Methods in org.apache.cassandra.utils.memory that return DecoratedKeyModifier and TypeMethodDescriptionabstract DecoratedKeyEnsureOnHeap.applyToPartitionKey(DecoratedKey key) ByteBufferCloner.clone(DecoratedKey key) Cloner.clone(DecoratedKey key) Clones the specified key.NativeAllocator.clone(DecoratedKey key, OpOrder.Group writeOp) Methods in org.apache.cassandra.utils.memory with parameters of type DecoratedKeyModifier and TypeMethodDescriptionabstract DecoratedKeyEnsureOnHeap.applyToPartitionKey(DecoratedKey key) ByteBufferCloner.clone(DecoratedKey key) Cloner.clone(DecoratedKey key) Clones the specified key.NativeAllocator.clone(DecoratedKey key, OpOrder.Group writeOp)