Uses of Class
org.apache.cassandra.db.DecoratedKey
-
-
Uses of DecoratedKey in org.apache.cassandra.cache
Constructors in org.apache.cassandra.cache with parameters of type DecoratedKey Constructor Description RowCacheKey(TableMetadata metadata, DecoratedKey key) -
Uses of DecoratedKey in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return types with arguments of type DecoratedKey Modifier and Type Method Description static java.util.Map<DecoratedKey,java.util.List<Row>>QueryProcessor. executeInternalRawWithNow(int nowInSec, java.lang.String query, java.lang.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 DecoratedKey Modifier and Type Method Description voidConstants.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)RowUpdateParameters. 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 DecoratedKey Constructor Description UpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, int nowInSec, int ttl, java.util.Map<DecoratedKey,Partition> prefetchedRows) -
Uses of DecoratedKey in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type DecoratedKey Modifier and Type Method Description voidResultSetBuilder. newRow(DecoratedKey partitionKey, Clustering<?> clustering)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 DecoratedKey Modifier and Type Field Description DecoratedKeyCQL3CasRequest. keyMethods in org.apache.cassandra.cql3.statements that return types with arguments of type DecoratedKey Modifier and Type Method Description java.util.Map<DecoratedKey,java.util.List<Row>>SelectStatement. executeRawInternal(QueryOptions options, ClientState state, int nowInSec)Methods in org.apache.cassandra.cql3.statements with parameters of type DecoratedKey Modifier and Type Method Description static java.nio.ByteBuffer[]SelectStatement. getComponents(TableMetadata metadata, DecoratedKey dk)PartitionUpdate.BuilderUpdatesCollector. getPartitionUpdateBuilder(TableMetadata metadata, DecoratedKey dk, ConsistencyLevel consistency)SinglePartitionReadCommandSelectStatement. internalReadForView(DecoratedKey key, int 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 DecoratedKey Constructor Description CQL3CasRequest(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.db Modifier and Type Class Description classBufferDecoratedKeyclassCachedHashDecoratedKeyclassNativeDecoratedKeyclassPreHashedDecoratedKeyFields in org.apache.cassandra.db declared as DecoratedKey Modifier and Type Field Description protected DecoratedKeySinglePartitionReadCommand. partitionKeyFields in org.apache.cassandra.db with type parameters of type DecoratedKey Modifier and Type Field Description static java.util.Comparator<DecoratedKey>DecoratedKey. comparatorMethods in org.apache.cassandra.db that return DecoratedKey Modifier and Type Method Description DecoratedKeyColumnFamilyStore. decorateKey(java.nio.ByteBuffer key)DecoratedKeyCounterMutation. key()DecoratedKeyIMutation. key()DecoratedKeyMutation. key()DecoratedKeyMutation.PartitionUpdateCollector. key()DecoratedKeySinglePartitionReadCommand. partitionKey()DecoratedKeySinglePartitionReadQuery. partitionKey()Returns the key of the partition queried by thisReadQueryMethods in org.apache.cassandra.db that return types with arguments of type DecoratedKey Modifier and Type Method Description java.lang.Iterable<DecoratedKey>ColumnFamilyStore. keySamples(Range<Token> range)Methods in org.apache.cassandra.db with parameters of type DecoratedKey Modifier and Type Method Description ClusteringIndexFilterDataRange. clusteringIndexFilter(DecoratedKey key)The clustering index filter to use for the provided key.ClusteringIndexFilterDataRange.Paging. clusteringIndexFilter(DecoratedKey key)ClusteringIndexFilterPartitionRangeReadCommand. clusteringIndexFilter(DecoratedKey key)abstract ClusteringIndexFilterReadCommand. clusteringIndexFilter(DecoratedKey key)The clustering index filter this command to use for the provided key.ClusteringIndexFilterSinglePartitionReadCommand. clusteringIndexFilter(DecoratedKey key)booleanColumnFamilyStore. containsCachedParition(DecoratedKey key)static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, java.util.NavigableSet<Clustering<?>> names)Creates a new single partition name command for the provided rows.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, Clustering<?> name)Creates a new single partition name command for the provided row.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter)Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, Slice slice)Creates a new single partition slice command for the provided single slice.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, Slices slices)Creates a new single partition slice command for the provided slices.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata indexMetadata)Creates a new read command on a single partition.static SinglePartitionReadQuerySinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter)Creates a new read query on a single partition.static SinglePartitionReadQuerySinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)Creates a new read query on a single partition.voidColumnFamilyStore. forceCompactionForKey(DecoratedKey key)static SinglePartitionReadCommandSinglePartitionReadCommand. fullPartitionRead(TableMetadata metadata, int nowInSec, DecoratedKey key)Creates a new read command that queries a single partition in its entirety.Directories.DataDirectoryDiskBoundaries. getCorrectDiskForKey(DecoratedKey key)BallotColumnFamilyStore. getPaxosRepairLowBound(DecoratedKey key)abstract java.util.function.LongPredicateAbstractCompactionController. getPurgeEvaluator(DecoratedKey key)CachedPartitionColumnFamilyStore. getRawCachedPartition(DecoratedKey key)static voidUnfilteredValidation. handleInvalid(TableMetadata metadata, DecoratedKey key, SSTableReader sstable, java.lang.String invalidContent)voidColumnFamilyStore. invalidateCachedPartition(DecoratedKey key)static PaxosState.SnapshotSystemKeyspace. loadPaxosState(DecoratedKey partitionKey, TableMetadata metadata, int nowInSec)Load the current paxos state for the table and key NOTE: nowInSec is typically provided as zero, and should not be assumed to be definitive, as the cache may apply different nowInSec filtersUnfilteredRowIteratorStorageHook. makeRowIterator(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)UnfilteredRowIteratorWithLowerBoundStorageHook. makeRowIteratorWithLowerBound(ColumnFamilyStore cfs, DecoratedKey partitionKey, SSTableReader sstable, 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)java.lang.Iterable<UnfilteredRowIterator>AbstractCompactionController. shadowSources(DecoratedKey key, boolean tombstoneOnly)static Mutation.SimpleBuilderMutation. simpleBuilder(java.lang.String keyspaceName, DecoratedKey partitionKey)Creates a new simple mutuation builder.java.lang.StringReadResponse. 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 DecoratedKey Modifier and Type Method Description static SinglePartitionReadCommand.GroupSinglePartitionReadCommand.Group. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery>SinglePartitionReadQuery. createGroup(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)Constructors in org.apache.cassandra.db with parameters of type DecoratedKey Constructor Description Mutation(java.lang.String keyspaceName, DecoratedKey key, com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications, long approxCreatedAtNanos)Mutation(java.lang.String keyspaceName, DecoratedKey key, com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications, long approxCreatedAtNanos, boolean cdcEnabled)MutationBuilder(java.lang.String keyspaceName, DecoratedKey key)PartitionUpdateCollector(java.lang.String keyspaceName, DecoratedKey key)SinglePartitionBuilder(ColumnFamilyStore cfs, DecoratedKey key)SinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata index, boolean trackWarnings)VirtualTableSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata index, boolean trackWarnings) -
Uses of DecoratedKey in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation with parameters of type DecoratedKey Modifier and Type Method Description abstract 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.columniterator
Fields in org.apache.cassandra.db.columniterator declared as DecoratedKey Modifier and Type Field Description protected DecoratedKeyAbstractSSTableIterator. keyMethods in org.apache.cassandra.db.columniterator that return DecoratedKey Modifier and Type Method Description DecoratedKeyAbstractSSTableIterator. partitionKey()Constructors in org.apache.cassandra.db.columniterator with parameters of type DecoratedKey Constructor Description AbstractSSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columnFilter, FileHandle ifile)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.db.compaction
Methods in org.apache.cassandra.db.compaction with parameters of type DecoratedKey Modifier and Type Method Description booleanVerifier.RangeOwnHelper. check(DecoratedKey key)check if the given key is contained in any of the given ranges Must be called in sorted order - key should be increasingvoidCompactionManager. forceCompactionForKey(ColumnFamilyStore cfStore, DecoratedKey key)java.util.function.LongPredicateCompactionController. getPurgeEvaluator(DecoratedKey key)java.util.function.LongPredicateSSTableSplitter.SplitController. getPurgeEvaluator(DecoratedKey key)java.lang.Iterable<UnfilteredRowIterator>CompactionController. shadowSources(DecoratedKey key, boolean tombstoneOnly)voidVerifier.RangeOwnHelper. validate(DecoratedKey key)check if the given key is contained in any of the given ranges Must be called in sorted order - key should be increasing -
Uses of DecoratedKey in org.apache.cassandra.db.compaction.writers
Methods in org.apache.cassandra.db.compaction.writers with parameters of type DecoratedKey Modifier and Type Method Description protected voidCompactionAwareWriter. maybeSwitchWriter(DecoratedKey key)Guaranteed to be called before the first call to realAppend. -
Uses of DecoratedKey in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter with parameters of type DecoratedKey Modifier and Type Method Description protected abstract voidDataLimits.Counter. applyToPartition(DecoratedKey partitionKey, Row staticRow)protected java.nio.ByteBufferRowFilter.Expression. getValue(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)booleanRowFilter.CustomExpression. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)abstract booleanRowFilter.Expression. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)Returns whether the provided row satisfied this expression or not.booleanRowFilter. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)Whether the provided row in the provided partition satisfies this filter.booleanRowFilter.SimpleExpression. isSatisfiedBy(TableMetadata metadata, DecoratedKey partitionKey, Row row, int nowInSec)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 DecoratedKey Constructor Description TombstoneOverwhelmingException(int numTombstones, java.lang.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 DecoratedKey Modifier and Type Method Description static com.google.common.base.Function<View,java.lang.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 DecoratedKey Modifier and Type Method Description UnfilteredRowIteratorShardedSkipListMemtable. rowIterator(DecoratedKey key)UnfilteredRowIteratorShardedSkipListMemtable. rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)UnfilteredRowIteratorSkipListMemtable. rowIterator(DecoratedKey key)UnfilteredRowIteratorSkipListMemtable. 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 DecoratedKey Modifier and Type Field Description protected DecoratedKeyAbstractBTreePartition. partitionKeyMethods in org.apache.cassandra.db.partitions that return DecoratedKey Modifier and Type Method Description DecoratedKeyAbstractBTreePartition. partitionKey()DecoratedKeyAtomicBTreePartition. partitionKey()DecoratedKeyPartition. partitionKey()DecoratedKeyPartitionUpdate.Builder. partitionKey()Methods in org.apache.cassandra.db.partitions with parameters of type DecoratedKey Modifier and Type Method Description static PartitionUpdatePartitionUpdate. emptyUpdate(TableMetadata metadata, DecoratedKey key)Creates a empty immutable partition update.static PartitionUpdatePartitionUpdate. fullPartitionDelete(TableMetadata metadata, DecoratedKey key, long timestamp, int nowInSec)Creates an immutable partition update that entirely deletes a given partition.UnfilteredRowIterators.MergeListenerUnfilteredPartitionIterators.MergeListener. getRowMergeListener(DecoratedKey partitionKey, java.util.List<UnfilteredRowIterator> versions)static booleanPartitionUpdate.PartitionUpdateSerializer. isEmpty(java.nio.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, AbstractBTreePartition.Holder holder, MutableDeletionInfo deletionInfo, boolean canHaveShadowedData)Constructors in org.apache.cassandra.db.partitions with parameters of type DecoratedKey Constructor Description AbstractBTreePartition(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)ImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, AbstractBTreePartition.Holder holder)ImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, RegularAndStaticColumns columns, Row staticRow, java.lang.Object[] tree, DeletionInfo deletionInfo, EncodingStats stats) -
Uses of DecoratedKey in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as DecoratedKey Modifier and Type Field Description DecoratedKeyUnfilteredRowIteratorSerializer.Header. keyprotected DecoratedKeyAbstractUnfilteredRowIterator. partitionKeyMethods in org.apache.cassandra.db.rows that return DecoratedKey Modifier and Type Method Description DecoratedKeyAbstractUnfilteredRowIterator. partitionKey()DecoratedKeyBaseRowIterator. partitionKey()The partition key of the partition this in an iterator over.DecoratedKeyLazilyInitializedUnfilteredRowIterator. partitionKey()DecoratedKeyWrappingUnfilteredRowIterator. partitionKey()Methods in org.apache.cassandra.db.rows with parameters of type DecoratedKey Modifier and Type Method Description static 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)UnfilteredRowIteratorUnfilteredSource. 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 DecoratedKey Constructor Description AbstractUnfilteredRowIterator(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, java.util.Iterator<Row> rows, java.util.Iterator<RangeTombstone> ranges, boolean removeShadowedData)UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener) -
Uses of DecoratedKey in org.apache.cassandra.db.streaming
Fields in org.apache.cassandra.db.streaming declared as DecoratedKey Modifier and Type Field Description DecoratedKeyCassandraStreamHeader. firstKeyprotected DecoratedKeyCassandraStreamReader.StreamDeserializer. keyMethods in org.apache.cassandra.db.streaming that return DecoratedKey Modifier and Type Method Description DecoratedKeyCassandraStreamReader.StreamDeserializer. partitionKey()Methods in org.apache.cassandra.db.streaming with parameters of type DecoratedKey Modifier and Type Method Description CassandraStreamHeader.BuilderCassandraStreamHeader.Builder. withFirstKey(DecoratedKey firstKey) -
Uses of DecoratedKey in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return DecoratedKey Modifier and Type Method Description protected DecoratedKeyTransformation. applyToPartitionKey(DecoratedKey key)Applied to the partition key of any rows/unfiltered iterator we are applied toDecoratedKeyBaseRows. partitionKey()Methods in org.apache.cassandra.db.transform with parameters of type DecoratedKey Modifier and Type Method Description protected 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 DecoratedKey Modifier and Type Method Description booleanView. matchesViewFilter(DecoratedKey partitionKey, Row baseRow, int 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 DecoratedKey Constructor Description ViewUpdateGenerator(View view, DecoratedKey basePartitionKey, int 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 DecoratedKey Modifier and Type Field Description protected java.util.NavigableMap<DecoratedKey,AbstractVirtualTable.Partition>AbstractVirtualTable.AbstractDataSet. partitionsMethods in org.apache.cassandra.db.virtual that return DecoratedKey Modifier and Type Method Description DecoratedKeyAbstractVirtualTable.Partition. key()DecoratedKeyVirtualMutation. key()Methods in org.apache.cassandra.db.virtual with parameters of type DecoratedKey Modifier and Type Method Description AbstractVirtualTable.DataSetAbstractVirtualTable. data(DecoratedKey partitionKey)Provide aAbstractVirtualTable.DataSetthat is potentially restricted to the provided partition - but is allowed to contain other partitions.AbstractVirtualTable.DataSetInternodeInboundTable. data(DecoratedKey partitionKey)AbstractVirtualTable.DataSetInternodeOutboundTable. data(DecoratedKey partitionKey)AbstractVirtualTable.DataSetStreamingVirtualTable. data(DecoratedKey partitionKey)static AbstractMutableVirtualTable.ColumnValuesAbstractMutableVirtualTable.ColumnValues. from(TableMetadata metadata, DecoratedKey partitionKey)Returns the set of column values corresponding to the specified partition key.AbstractVirtualTable.PartitionAbstractVirtualTable.AbstractDataSet. getPartition(DecoratedKey key)AbstractVirtualTable.PartitionAbstractVirtualTable.DataSet. getPartition(DecoratedKey partitionKey)UnfilteredPartitionIteratorAbstractVirtualTable. select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter)UnfilteredPartitionIteratorVirtualTable. 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 DecoratedKey Constructor Description VirtualMutation(java.lang.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 DecoratedKey Constructor Description AbstractDataSet(java.util.NavigableMap<DecoratedKey,AbstractVirtualTable.Partition> partitions) -
Uses of DecoratedKey in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht that return DecoratedKey Modifier and Type Method Description DecoratedKeyByteOrderedPartitioner. decorateKey(java.nio.ByteBuffer key)DecoratedKeyIPartitioner. decorateKey(java.nio.ByteBuffer key)Transform key to object representation of the on-disk format.DecoratedKeyLocalPartitioner. decorateKey(java.nio.ByteBuffer key)DecoratedKeyMurmur3Partitioner. decorateKey(java.nio.ByteBuffer key)DecoratedKeyOrderPreservingPartitioner. decorateKey(java.nio.ByteBuffer key)DecoratedKeyRandomPartitioner. decorateKey(java.nio.ByteBuffer key) -
Uses of DecoratedKey in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type DecoratedKey Modifier and Type Method Description Index.IndexerIndex. indexerFor(DecoratedKey key, RegularAndStaticColumns columns, int nowInSec, WriteContext ctx, IndexTransaction.Type transactionType)Creates an newIndexerobject for updates to a given partition.voidSecondaryIndexManager. indexPartition(DecoratedKey key, java.util.Set<Index> indexes, int pageSize)voidSecondaryIndexManager. indexPartition(DecoratedKey key, java.util.Set<Index> indexes, int pageSize, RegularAndStaticColumns columns)When building an index against existing data in sstables, add the given partition to the indexCleanupTransactionSecondaryIndexManager. newCleanupTransaction(DecoratedKey key, RegularAndStaticColumns regularAndStaticColumns, int nowInSec)Transaction for use when removing partitions during cleanupCompactionTransactionSecondaryIndexManager. newCompactionTransaction(DecoratedKey key, RegularAndStaticColumns regularAndStaticColumns, int versions, int 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 DecoratedKey Modifier and Type Field Description DecoratedKeyIndexEntry. indexValueMethods in org.apache.cassandra.index.internal with parameters of type DecoratedKey Modifier and Type Method Description abstract 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 indexIndex.IndexerCassandraIndex. indexerFor(DecoratedKey key, RegularAndStaticColumns columns, int nowInSec, WriteContext ctx, IndexTransaction.Type transactionType)protected abstract UnfilteredPartitionIteratorCassandraIndexSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController)Constructors in org.apache.cassandra.index.internal with parameters of type DecoratedKey Constructor Description IndexEntry(DecoratedKey indexValue, Clustering<?> indexClustering, long timestamp, java.nio.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 DecoratedKey Modifier and Type Method Description IndexEntryClusteringColumnIndex. decodeEntry(DecoratedKey indexedValue, Row indexEntry)IndexEntryCollectionKeyIndexBase. decodeEntry(DecoratedKey indexedValue, Row indexEntry)IndexEntryCollectionValueIndex. decodeEntry(DecoratedKey indexedValue, Row indexEntry)IndexEntryPartitionKeyIndex. decodeEntry(DecoratedKey indexedValue, Row indexEntry)IndexEntryRegularColumnIndex. 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 DecoratedKey Modifier and Type Method Description IndexEntryKeysIndex. decodeEntry(DecoratedKey indexedValue, Row indexEntry)protected UnfilteredPartitionIteratorKeysSearcher. queryDataFromIndex(DecoratedKey indexKey, RowIterator indexHits, ReadCommand command, ReadExecutionController executionController) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type DecoratedKey Modifier and Type Method Description Index.IndexerSASIIndex. indexerFor(DecoratedKey key, RegularAndStaticColumns columns, int nowInSec, WriteContext context, IndexTransaction.Type transactionType) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi.conf
Methods in org.apache.cassandra.index.sasi.conf with parameters of type DecoratedKey Modifier and Type Method Description longColumnIndex. index(DecoratedKey key, Row row) -
Uses of DecoratedKey in org.apache.cassandra.index.sasi.disk
Fields in org.apache.cassandra.index.sasi.disk with type parameters of type DecoratedKey Modifier and Type Field Description protected com.google.common.base.Function<java.lang.Long,DecoratedKey>OnDiskIndex. keyFetcherMethods in org.apache.cassandra.index.sasi.disk that return types with arguments of type DecoratedKey Modifier and Type Method Description java.util.Iterator<DecoratedKey>TokenTree.OnDiskToken. iterator()Methods in org.apache.cassandra.index.sasi.disk with parameters of type DecoratedKey Modifier and Type Method Description OnDiskIndexBuilderOnDiskIndexBuilder. add(java.nio.ByteBuffer term, DecoratedKey key, long keyPosition)voidPerSSTableIndexWriter.Index. add(java.nio.ByteBuffer term, DecoratedKey key, long keyPosition)voidPerSSTableIndexWriter. startPartition(DecoratedKey key, long curPosition)Method parameters in org.apache.cassandra.index.sasi.disk with type arguments of type DecoratedKey Modifier and Type Method Description TokenTree.OnDiskTokenTokenTree. get(long searchToken, com.google.common.base.Function<java.lang.Long,DecoratedKey> keyFetcher)static TokenTree.OnDiskTokenTokenTree.OnDiskToken. getTokenAt(MappedBuffer buffer, int idx, short leafSize, com.google.common.base.Function<java.lang.Long,DecoratedKey> keyFetcher)RangeIterator<java.lang.Long,Token>TokenTree. iterator(com.google.common.base.Function<java.lang.Long,DecoratedKey> keyFetcher)Constructor parameters in org.apache.cassandra.index.sasi.disk with type arguments of type DecoratedKey Constructor Description OnDiskIndex(File index, AbstractType<?> cmp, com.google.common.base.Function<java.lang.Long,DecoratedKey> keyReader)OnDiskToken(MappedBuffer buffer, long position, short leafSize, com.google.common.base.Function<java.lang.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 DecoratedKey Modifier and Type Method Description java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>TrieMemIndex.ConcurrentPrefixTrie. get(java.lang.String value)java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>TrieMemIndex.ConcurrentSuffixTrie. get(java.lang.String value)java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>TrieMemIndex.ConcurrentPrefixTrie. putIfAbsent(java.lang.String value, java.util.concurrent.ConcurrentSkipListSet<DecoratedKey> newKeys)java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>TrieMemIndex.ConcurrentSuffixTrie. putIfAbsent(java.lang.String value, java.util.concurrent.ConcurrentSkipListSet<DecoratedKey> newKeys)java.lang.Iterable<java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>>TrieMemIndex.ConcurrentPrefixTrie. search(Expression.Op operator, java.lang.String value)java.lang.Iterable<java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>>TrieMemIndex.ConcurrentSuffixTrie. search(Expression.Op operator, java.lang.String value)Methods in org.apache.cassandra.index.sasi.memory with parameters of type DecoratedKey Modifier and Type Method Description abstract longMemIndex. add(DecoratedKey key, java.nio.ByteBuffer value)longSkipListMemIndex. add(DecoratedKey key, java.nio.ByteBuffer value)longTrieMemIndex. add(DecoratedKey key, java.nio.ByteBuffer value)longIndexMemtable. index(DecoratedKey key, java.nio.ByteBuffer value)Method parameters in org.apache.cassandra.index.sasi.memory with type arguments of type DecoratedKey Modifier and Type Method Description java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>TrieMemIndex.ConcurrentPrefixTrie. putIfAbsent(java.lang.String value, java.util.concurrent.ConcurrentSkipListSet<DecoratedKey> newKeys)java.util.concurrent.ConcurrentSkipListSet<DecoratedKey>TrieMemIndex.ConcurrentSuffixTrie. putIfAbsent(java.lang.String value, java.util.concurrent.ConcurrentSkipListSet<DecoratedKey> newKeys)Constructor parameters in org.apache.cassandra.index.sasi.memory with type arguments of type DecoratedKey Constructor Description KeyRangeIterator(java.util.concurrent.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 DecoratedKey Modifier and Type Method Description UnfilteredRowIteratorQueryController. getPartition(DecoratedKey key, ReadExecutionController executionController) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as DecoratedKey Modifier and Type Field Description DecoratedKeySSTable. firstDecoratedKeySSTable. lastDecoratedKeyIndexSummaryBuilder.ReadableBoundary. lastKeyMethods in org.apache.cassandra.io.sstable that return DecoratedKey Modifier and Type Method Description protected DecoratedKeyKeyIterator. computeNext()DecoratedKeySSTable. decorateKey(java.nio.ByteBuffer key)static DecoratedKeySSTable. getMinimalKey(DecoratedKey key)If the given @param key occupies only part of a larger buffer, allocate a new buffer that is only as large as necessary.DecoratedKeyReducingKeyIterator. next()DecoratedKeySSTableIdentityIterator. partitionKey()Methods in org.apache.cassandra.io.sstable that return types with arguments of type DecoratedKey Modifier and Type Method Description Pair<DecoratedKey,DecoratedKey>IndexSummary.IndexSummarySerializer. deserializeFirstLastKey(java.io.DataInputStream in, IPartitioner partitioner)Deserializes the first and last key stored in the summary Only for use by offline tools like SSTableMetadataViewer, otherwise SSTable.first/last should be used.Pair<DecoratedKey,DecoratedKey>IndexSummary.IndexSummarySerializer. deserializeFirstLastKey(java.io.DataInputStream in, IPartitioner partitioner)Deserializes the first and last key stored in the summary Only for use by offline tools like SSTableMetadataViewer, otherwise SSTable.first/last should be used.Methods in org.apache.cassandra.io.sstable with parameters of type DecoratedKey Modifier and Type Method Description static SSTableIdentityIteratorSSTableIdentityIterator. create(SSTableReader sstable, FileDataInput dfile, RowIndexEntry<?> indexEntry, DecoratedKey key, boolean tombstoneOnly)static SSTableIdentityIteratorSSTableIdentityIterator. create(SSTableReader sstable, RandomAccessReader file, DecoratedKey key)static DecoratedKeySSTable. getMinimalKey(DecoratedKey key)If the given @param key occupies only part of a larger buffer, allocate a new buffer that is only as large as necessary.IndexSummaryBuilderIndexSummaryBuilder. maybeAddEntry(DecoratedKey decoratedKey, long indexStart)IndexSummaryBuilderIndexSummaryBuilder. maybeAddEntry(DecoratedKey decoratedKey, long indexStart, long indexEnd, long dataEnd)Constructors in org.apache.cassandra.io.sstable with parameters of type DecoratedKey Constructor Description ReadableBoundary(DecoratedKey lastKey, long indexLength, long dataLength, int summaryCount, long entriesLength)SSTableIdentityIterator(SSTableReader sstable, DecoratedKey key, DeletionTime partitionLevelDeletion, java.lang.String filename, SSTableSimpleIterator iterator) -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as DecoratedKey Modifier and Type Field Description protected DecoratedKeySSTableReaderBuilder. firstprotected DecoratedKeySSTableReaderBuilder. lastMethods in org.apache.cassandra.io.sstable.format that return DecoratedKey Modifier and Type Method Description DecoratedKeySSTableReader. firstKeyBeyond(PartitionPosition token)Finds and returns the first key beyond a given token in this SSTable or null if no such key exists.DecoratedKeySSTableReader. keyAt(long indexPosition)Methods in org.apache.cassandra.io.sstable.format that return types with arguments of type DecoratedKey Modifier and Type Method Description java.lang.Iterable<DecoratedKey>SSTableReader. getKeySamples(Range<Token> range)Methods in org.apache.cassandra.io.sstable.format with parameters of type DecoratedKey Modifier and Type Method Description voidSSTableReader. cacheKey(DecoratedKey key, RowIndexEntry info)SSTableReaderSSTableReader. cloneWithNewStart(DecoratedKey newStart, java.lang.Runnable runOnClose)SSTableReaderSSTableReader. cloneWithRestoredStart(DecoratedKey restoredStart)RowIndexEntrySSTableReader. getCachedPosition(DecoratedKey key, boolean updateStats)KeyCacheKeySSTableReader. getCacheKey(DecoratedKey key)static voidSSTableWriter. guardCollectionSize(TableMetadata metadata, DecoratedKey partitionKey, Unfiltered unfiltered)booleanSSTableReader. maybePresent(DecoratedKey key)abstract UnfilteredRowIteratorSSTableReader. rowIterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed)static voidSSTableReader. saveSummary(Descriptor descriptor, DecoratedKey first, DecoratedKey last, IndexSummary summary)Save index summary to Summary.db file.abstract UnfilteredRowIteratorSSTableReader. simpleIterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, boolean tombstoneOnly)voidSSTableFlushObserver. startPartition(DecoratedKey key, long indexPosition)Called when a new partition in being written to the sstable, but before any cells are processed (seeSSTableFlushObserver.nextUnfilteredCluster(Unfiltered)). -
Uses of DecoratedKey in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type DecoratedKey Modifier and Type Method Description protected longBigTableWriter. beforeAppend(DecoratedKey decoratedKey)Perform sanity checks on @param decoratedKey and @return the position in the data file before any data is writtenUnfilteredRowIteratorBigTableReader. rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)UnfilteredRowIteratorBigTableReader. rowIterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed)UnfilteredRowIteratorBigTableReader. simpleIterator(FileDataInput dfile, DecoratedKey key, RowIndexEntry position, boolean tombstoneOnly) -
Uses of DecoratedKey in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return DecoratedKey Modifier and Type Method Description DecoratedKeyTokenMetadata. decorateKey(java.nio.ByteBuffer key)Methods in org.apache.cassandra.locator with parameters of type DecoratedKey Modifier and Type Method Description static 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 DecoratedKey Modifier and Type Field Description DecoratedKeyTopPartitionTracker.TopPartition. keyMethods in org.apache.cassandra.metrics with parameters of type DecoratedKey Modifier and Type Method Description voidTopPartitionTracker.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 Constructor Description TopPartition(DecoratedKey key, long value) -
Uses of DecoratedKey in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return DecoratedKey Modifier and Type Method Description DecoratedKeyStorageService. getKeyFromPartition(java.lang.String keyspaceName, java.lang.String table, java.lang.String partitionKey)Methods in org.apache.cassandra.service with parameters of type DecoratedKey Modifier and Type Method Description static RowIteratorStorageProxy. cas(java.lang.String keyspaceName, java.lang.String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, int 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(java.lang.String keyspaceName, java.lang.String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, int nowInSeconds, Dispatcher.RequestTime requestTime) -
Uses of DecoratedKey in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type DecoratedKey Modifier and Type Method Description protected 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 DecoratedKey Constructor Description PartitionRangeQueryPager(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 DecoratedKey Modifier and Type Method Description DecoratedKeyAbstractPaxosRepair. partitionKey()Methods in org.apache.cassandra.service.paxos with parameters of type DecoratedKey Modifier and Type Method Description static 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 DecoratedKey Constructor Description AbstractPaxosRepair(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 DecoratedKey Modifier and Type Method Description DecoratedKeyPaxosKeyState. getKey()DecoratedKeyUncommittedPaxosKey. getKey()Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type DecoratedKey Modifier and Type Method Description static Commit.CommittedPaxosRows. getCommitted(TableMetadata metadata, DecoratedKey partitionKey, Row row, long purgeBefore, long overrideTtlSeconds)Index.IndexerPaxosUncommittedIndex. indexerFor(DecoratedKey key, RegularAndStaticColumns columns, int nowInSec, WriteContext ctx, IndexTransaction.Type transactionType)Constructors in org.apache.cassandra.service.paxos.uncommitted with parameters of type DecoratedKey Constructor Description PaxosKeyState(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 DecoratedKey Constructor Description PrepareCallback(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 Modifier and Type Method Description DecoratedKeyAbstractReadExecutor. getKey() -
Uses of DecoratedKey in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type DecoratedKey Modifier and Type Method Description UnfilteredRowIterators.MergeListenerPartitionIteratorMergeListener. getRowMergeListener(DecoratedKey partitionKey, java.util.List<UnfilteredRowIterator> versions)voidBlockingReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)voidNoopReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)voidReadOnlyReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)voidReadRepair. repairPartition(DecoratedKey partitionKey, java.util.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 DecoratedKey Constructor Description BlockingPartitionRepair(DecoratedKey key, java.util.Map<Replica,Mutation> repairs, ReplicaPlan.ForWrite writePlan)RowIteratorMergeListener(DecoratedKey partitionKey, RegularAndStaticColumns columns, boolean isReversed, ReplicaPlan.ForRead<E,?> readPlan, ReadCommand command, ReadRepair readRepair) -
Uses of DecoratedKey in org.apache.cassandra.streaming
Constructors in org.apache.cassandra.streaming with parameters of type DecoratedKey Constructor Description StreamReceivedOutOfTokenRangeException(java.util.Collection<Range<Token>> ownedRanges, DecoratedKey key, java.lang.String filename) -
Uses of DecoratedKey in org.apache.cassandra.tools
Method parameters in org.apache.cassandra.tools with type arguments of type DecoratedKey Modifier and Type Method Description static voidJsonTransformer. keysToJson(ISSTableScanner currentScanner, java.util.stream.Stream<DecoratedKey> keys, boolean rawTime, TableMetadata metadata, java.io.OutputStream out) -
Uses of DecoratedKey in org.apache.cassandra.utils
Method parameters in org.apache.cassandra.utils with type arguments of type DecoratedKey Modifier and Type Method Description static voidFBUtilities. sortSampledKeys(java.util.List<DecoratedKey> keys, Range<Token> range) -
Uses of DecoratedKey in org.apache.cassandra.utils.memory
Methods in org.apache.cassandra.utils.memory that return DecoratedKey Modifier and Type Method Description abstract DecoratedKeyEnsureOnHeap. applyToPartitionKey(DecoratedKey key)DecoratedKeyByteBufferCloner. clone(DecoratedKey key)DecoratedKeyCloner. clone(DecoratedKey key)Clones the specified key.DecoratedKeyNativeAllocator. clone(DecoratedKey key, OpOrder.Group writeOp)Methods in org.apache.cassandra.utils.memory with parameters of type DecoratedKey Modifier and Type Method Description abstract DecoratedKeyEnsureOnHeap. applyToPartitionKey(DecoratedKey key)DecoratedKeyByteBufferCloner. clone(DecoratedKey key)DecoratedKeyCloner. clone(DecoratedKey key)Clones the specified key.DecoratedKeyNativeAllocator. clone(DecoratedKey key, OpOrder.Group writeOp)
-