Uses of Interface
org.apache.cassandra.db.rows.Row
-
-
Uses of Row in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return Row Modifier and Type Method Description RowUpdateParameters. buildRow()RowUpdateParameters. getPrefetchedRow(DecoratedKey key, Clustering<?> clustering)Returns the prefetched row with the already performed modifications.Methods in org.apache.cassandra.cql3 that return types with arguments of type Row 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 Row Modifier and Type Method Description static UntypedResultSet.RowUntypedResultSet.Row. fromInternalRow(TableMetadata metadata, DecoratedKey key, Row row) -
Uses of Row in org.apache.cassandra.cql3.conditions
Methods in org.apache.cassandra.cql3.conditions with parameters of type Row Modifier and Type Method Description abstract booleanColumnCondition.Bound. appliesTo(Row row)Validates whether this condition applies tocurrent.protected static Cell<?>ColumnCondition. getCell(Row row, ColumnMetadata column)protected static Cell<?>ColumnCondition. getCell(Row row, ColumnMetadata column, CellPath path)protected static java.util.Iterator<Cell<?>>ColumnCondition. getCells(Row row, ColumnMetadata column) -
Uses of Row in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return types with arguments of type Row Modifier and Type Method Description java.util.Map<DecoratedKey,java.util.List<Row>>SelectStatement. executeRawInternal(QueryOptions options, ClientState state, int nowInSec) -
Uses of Row in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return Row Modifier and Type Method Description protected RowReadCommand.CheckForAbort. applyToRow(Row row)RowSimpleBuilders.RowBuilder. build()Methods in org.apache.cassandra.db that return types with arguments of type Row Modifier and Type Method Description java.util.Comparator<Row>ClusteringComparator. rowComparator()A comparator for rows.Methods in org.apache.cassandra.db with parameters of type Row Modifier and Type Method Description protected RowReadCommand.CheckForAbort. applyToRow(Row row)static ColumnsColumns. from(Row row)Returns a newColumnsobject holing the same columns as the provided Row.static UnfilteredRowIteratorEmptyIterators. unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder, Row staticRow, DeletionTime partitionDeletion) -
Uses of Row in org.apache.cassandra.db.columniterator
Fields in org.apache.cassandra.db.columniterator declared as Row Modifier and Type Field Description protected RowAbstractSSTableIterator. staticRowMethods in org.apache.cassandra.db.columniterator that return Row Modifier and Type Method Description RowAbstractSSTableIterator. staticRow() -
Uses of Row in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter with parameters of type Row 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)protected booleanDataLimits.Counter. isLive(Row row)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) -
Uses of Row in org.apache.cassandra.db.partitions
Fields in org.apache.cassandra.db.partitions declared as Row Modifier and Type Field Description RowAbstractBTreePartition.Holder. staticRowMethods in org.apache.cassandra.db.partitions that return Row Modifier and Type Method Description protected RowPurgeFunction. applyToRow(Row row)protected RowPurgeFunction. applyToStatic(Row row)RowAbstractBTreePartition. getRow(Clustering<?> clustering)RowAtomicBTreePartition. getRow(Clustering<?> clustering)RowPartition. getRow(Clustering<?> clustering)Returns the row corresponding to the provided clustering, or null if there is not such row.RowAbstractBTreePartition. lastRow()RowAtomicBTreePartition. lastRow()RowCachedPartition. lastRow()The last row in this cached partition (in order words, the row with the biggest clustering that the partition contains).RowAbstractBTreePartition. staticRow()RowAtomicBTreePartition. staticRow()Methods in org.apache.cassandra.db.partitions that return types with arguments of type Row Modifier and Type Method Description java.util.Iterator<Row>AbstractBTreePartition. iterator()java.util.Iterator<Row>AtomicBTreePartition. iterator()Methods in org.apache.cassandra.db.partitions with parameters of type Row Modifier and Type Method Description voidPartitionUpdate.Builder. add(Row row)Adds a row to this update.protected RowPurgeFunction. applyToRow(Row row)protected RowPurgeFunction. applyToStatic(Row row)static PartitionUpdatePartitionUpdate. singleRowUpdate(TableMetadata metadata, java.nio.ByteBuffer key, Row row)Creates an immutable partition update that contains a single row update.static PartitionUpdatePartitionUpdate. singleRowUpdate(TableMetadata metadata, DecoratedKey key, Row row)Creates an immutable partition update that contains a single row update.static PartitionUpdatePartitionUpdate. singleRowUpdate(TableMetadata metadata, DecoratedKey key, Row row, Row staticRow)Creates an immutable partition update that contains a single row update.static AbstractBTreePartition.HolderAbstractBTreePartition. unsafeConstructHolder(RegularAndStaticColumns columns, java.lang.Object[] tree, DeletionInfo deletionInfo, Row staticRow, EncodingStats stats)Constructors in org.apache.cassandra.db.partitions with parameters of type Row Constructor Description ImmutableBTreePartition(TableMetadata metadata, DecoratedKey partitionKey, RegularAndStaticColumns columns, Row staticRow, java.lang.Object[] tree, DeletionInfo deletionInfo, EncodingStats stats) -
Uses of Row in org.apache.cassandra.db.rows
Classes in org.apache.cassandra.db.rows that implement Row Modifier and Type Class Description classAbstractRowBase abstract class forRowimplementations.classBTreeRowImmutable implementation of a Row object.Fields in org.apache.cassandra.db.rows declared as Row Modifier and Type Field Description static RowRows. EMPTY_STATIC_ROWprotected RowAbstractUnfilteredRowIterator. staticRowRowUnfilteredRowIteratorSerializer.Header. staticRowMethods in org.apache.cassandra.db.rows that return Row Modifier and Type Method Description protected RowWithOnlyQueriedData. applyToRow(Row row)protected RowWithOnlyQueriedData. applyToStatic(Row row)RowBTreeRow.Builder. build()RowRow.Builder. build()Builds and return built row.RowRow.SimpleBuilder. build()Returns the built row.RowBTreeRow. clone(Cloner cloner)RowRow. clone(Cloner cloner)RowUnfilteredSerializer. deserializeRowBody(DataInputPlus in, SerializationHeader header, DeserializationHelper helper, int flags, int extendedFlags, Row.Builder builder)RowUnfilteredSerializer. deserializeStaticRow(DataInputPlus in, SerializationHeader header, DeserializationHelper helper)RowBTreeRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)RowBTreeRow. filter(ColumnFilter filter, TableMetadata metadata)RowRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)Returns a copy of this row that: 1) only includes the data for the column included byfilter.RowRow. filter(ColumnFilter filter, TableMetadata metadata)Returns a copy of this row that: 1) only includes the data for the column included byfilter.RowBTreeRow. markCounterLocalToBeCleared()RowRow. markCounterLocalToBeCleared()Returns a copy of this row where all counter cells have they "local" shard marked for clearing.static RowBTreeRow. merge(BTreeRow existing, BTreeRow update, ColumnData.PostReconciliationFunction reconcileF)RowRow.Merger. merge(DeletionTime activeDeletion)static RowRows. merge(Row existing, Row update)static RowRows. merge(Row existing, Row update, ColumnData.PostReconciliationFunction onReconcile)Merges two rows.Row[]Row.Merger. mergedRows()RowUnfilteredRowIterators.MergeListener. onMergedRows(Row merged, Row[] versions)Called once for every row participating in the merge.RowBTreeRow. purge(DeletionPurger purger, int nowInSec, boolean enforceStrictLiveness)RowRow. purge(DeletionPurger purger, int nowInSec, boolean enforceStrictLiveness)Returns a copy of this row without any deletion info that should be purged according topurger.RowBTreeRow. purgeDataOlderThan(long timestamp, boolean enforceStrictLiveness)RowRow. purgeDataOlderThan(long timestamp, boolean enforceStrictLiveness)static RowRows. removeShadowedCells(Row existing, Row update, DeletionTime rangeDeletion)Returns a row that is obtained from the given existing row by removing everything that is shadowed by data in the update row.RowAbstractUnfilteredRowIterator. staticRow()RowBaseRowIterator. staticRow()The static part corresponding to this partition (this can be an empty row but cannot benull).RowLazilyInitializedUnfilteredRowIterator. staticRow()RowUnfilteredRowIteratorWithLowerBound. staticRow()RowWrappingUnfilteredRowIterator. staticRow()RowBTreeRow. transform(java.util.function.Function<ColumnData,ColumnData> function)RowBTreeRow. transformAndFilter(java.util.function.Function<ColumnData,ColumnData> function)RowBTreeRow. transformAndFilter(LivenessInfo info, Row.Deletion deletion, java.util.function.Function<ColumnData,ColumnData> function)RowRow. transformAndFilter(java.util.function.Function<ColumnData,ColumnData> function)Requires thatfunctionreturns eithernullorColumnDatafor the same column.RowRow. transformAndFilter(LivenessInfo info, Row.Deletion deletion, java.util.function.Function<ColumnData,ColumnData> function)Requires thatfunctionreturns eithernullorColumnDatafor the same column.RowBTreeRow. updateAllTimestamp(long newTimestamp)Returns a copy of the row where all timestamps for live data have replaced bynewTimestampand all deletion timestamp bynewTimestamp - 1.RowRow. updateAllTimestamp(long newTimestamp)Returns a copy of this row where all live timestamp have been replaced bynewTimestampand every deletion timestamp bynewTimestamp - 1.RowBTreeRow. withOnlyQueriedData(ColumnFilter filter)RowRow. withOnlyQueriedData(ColumnFilter filter)Returns a copy of this row which only include the data queried byfilter, excluding anything _fetched_ for internal reasons but not queried by the user (seeColumnFilterfor details).RowBTreeRow. withRowDeletion(DeletionTime newDeletion)RowRow. withRowDeletion(DeletionTime deletion)Returns a copy of this row with the new deletion as row deletion if it is more recent than the current row deletion.Methods in org.apache.cassandra.db.rows with parameters of type Row Modifier and Type Method Description voidRow.Merger. add(int i, Row row)protected RowWithOnlyQueriedData. applyToRow(Row row)protected RowWithOnlyQueriedData. applyToStatic(Row row)static EncodingStatsEncodingStats.Collector. collect(Row staticRow, java.util.Iterator<Row> rows, DeletionInfo deletionInfo)static intRows. collectStats(Row row, PartitionStatisticsCollector collector)Collect statistics on a given row.static voidRows. diff(RowDiffListener diffListener, Row merged, Row... inputs)Given the result (merged) of merging multipleinputs, signals the difference between each input andmergedtodiffListener.static booleanUnfilteredSerializer. hasExtendedFlags(Row row)static RowRows. merge(Row existing, Row update)static RowRows. merge(Row existing, Row update, ColumnData.PostReconciliationFunction onReconcile)Merges two rows.static UnfilteredRowIteratorUnfilteredRowIterators. noRowsIterator(TableMetadata metadata, DecoratedKey partitionKey, Row staticRow, DeletionTime partitionDeletion, boolean isReverseOrder)Returns an empty unfiltered iterator for a given partition.RowUnfilteredRowIterators.MergeListener. onMergedRows(Row merged, Row[] versions)Called once for every row participating in the merge.static RowRows. removeShadowedCells(Row existing, Row update, DeletionTime rangeDeletion)Returns a row that is obtained from the given existing row by removing everything that is shadowed by data in the update row.voidUnfilteredSerializer. serializeStaticRow(Row row, SerializationHelper helper, DataOutputPlus out, int version)static UnfilteredRowIteratorUnfilteredRowIterators. singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats)Method parameters in org.apache.cassandra.db.rows with type arguments of type Row Modifier and Type Method Description static EncodingStatsEncodingStats.Collector. collect(Row staticRow, java.util.Iterator<Row> rows, DeletionInfo deletionInfo)Constructors in org.apache.cassandra.db.rows with parameters of type Row Constructor Description AbstractUnfilteredRowIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats stats)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)Constructor parameters in org.apache.cassandra.db.rows with type arguments of type Row Constructor Description RowAndDeletionMergeIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, ColumnFilter selection, Row staticRow, boolean isReversed, EncodingStats stats, java.util.Iterator<Row> rows, java.util.Iterator<RangeTombstone> ranges, boolean removeShadowedData) -
Uses of Row in org.apache.cassandra.db.streaming
Fields in org.apache.cassandra.db.streaming declared as Row Modifier and Type Field Description protected RowCassandraStreamReader.StreamDeserializer. staticRowMethods in org.apache.cassandra.db.streaming that return Row Modifier and Type Method Description RowCassandraStreamReader.StreamDeserializer. staticRow() -
Uses of Row in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return Row Modifier and Type Method Description protected RowDuplicateRowChecker. applyToRow(Row row)protected RowFilter. applyToRow(Row row)protected RowTransformation. applyToRow(Row row)Applied to any row we encounter in a rows iteratorprotected RowDuplicateRowChecker. applyToStatic(Row row)protected RowFilter. applyToStatic(Row row)protected RowTransformation. applyToStatic(Row row)Applied to the static row of any rows iterator.RowBaseRows. staticRow()Methods in org.apache.cassandra.db.transform with parameters of type Row Modifier and Type Method Description protected RowDuplicateRowChecker. applyToRow(Row row)protected RowFilter. applyToRow(Row row)protected RowTransformation. applyToRow(Row row)Applied to any row we encounter in a rows iteratorprotected RowDuplicateRowChecker. applyToStatic(Row row)protected RowFilter. applyToStatic(Row row)protected RowTransformation. applyToStatic(Row row)Applied to the static row of any rows iterator. -
Uses of Row in org.apache.cassandra.db.view
Methods in org.apache.cassandra.db.view with parameters of type Row Modifier and Type Method Description voidViewUpdateGenerator. addBaseTableUpdate(Row existingBaseRow, Row mergedBaseRow)Adds to this generator the updates to be made to the view given a base table row before and after an update.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. -
Uses of Row in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type Row Modifier and Type Method Description voidIndex.Indexer. insertRow(Row row)Notification that a new row was inserted into the Memtable holding the partition.voidIndex.Indexer. removeRow(Row row)Notification that a row was removed from the partition.voidIndex.Indexer. updateRow(Row oldRowData, Row newRowData)Notification of a modification to a row in the base table's Memtable. -
Uses of Row in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal with parameters of type Row 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.abstract booleanCassandraIndex. isStale(Row row, java.nio.ByteBuffer indexValue, int nowInSec)Check whether a value retrieved from an index is still valid by comparing it to current row from the base table. -
Uses of Row in org.apache.cassandra.index.internal.composites
Methods in org.apache.cassandra.index.internal.composites with parameters of type Row 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)booleanClusteringColumnIndex. isStale(Row data, java.nio.ByteBuffer indexValue, int nowInSec)booleanCollectionEntryIndex. isStale(Row data, java.nio.ByteBuffer indexValue, int nowInSec)booleanCollectionKeyIndex. isStale(Row data, java.nio.ByteBuffer indexValue, int nowInSec)booleanCollectionValueIndex. isStale(Row data, java.nio.ByteBuffer indexValue, int nowInSec)booleanPartitionKeyIndex. isStale(Row data, java.nio.ByteBuffer indexValue, int nowInSec)booleanRegularColumnIndex. isStale(Row data, java.nio.ByteBuffer indexValue, int nowInSec) -
Uses of Row in org.apache.cassandra.index.internal.keys
Methods in org.apache.cassandra.index.internal.keys with parameters of type Row Modifier and Type Method Description IndexEntryKeysIndex. decodeEntry(DecoratedKey indexedValue, Row indexEntry)booleanKeysIndex. isStale(Row row, java.nio.ByteBuffer indexValue, int nowInSec) -
Uses of Row in org.apache.cassandra.index.sasi.conf
Methods in org.apache.cassandra.index.sasi.conf with parameters of type Row Modifier and Type Method Description static java.nio.ByteBufferColumnIndex. getValueOf(ColumnMetadata column, Row row, int nowInSecs)longColumnIndex. index(DecoratedKey key, Row row) -
Uses of Row in org.apache.cassandra.index.sasi.plan
Methods in org.apache.cassandra.index.sasi.plan with parameters of type Row Modifier and Type Method Description booleanOperation. satisfiedBy(Unfiltered currentCluster, Row staticRow, boolean allowMissingColumns)Recursive "satisfies" checks based on operation and data from the lower level members using depth-first search and bubbling the results back to the top level caller. -
Uses of Row in org.apache.cassandra.index.transactions
Methods in org.apache.cassandra.index.transactions with parameters of type Row Modifier and Type Method Description voidUpdateTransaction. onInserted(Row row)voidCleanupTransaction. onRowDelete(Row row)voidCompactionTransaction. onRowMerge(Row merged, Row... versions)voidUpdateTransaction. onUpdated(Row existing, Row updated) -
Uses of Row in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return Row Modifier and Type Method Description RowSSTableSimpleIterator.EmptySSTableSimpleIterator. readStaticRow()abstract RowSSTableSimpleIterator. readStaticRow()RowSSTableIdentityIterator. staticRow() -
Uses of Row in org.apache.cassandra.metrics
Methods in org.apache.cassandra.metrics that return Row Modifier and Type Method Description RowTopPartitionTracker.TombstoneCounter. applyToRow(Row row)Methods in org.apache.cassandra.metrics with parameters of type Row Modifier and Type Method Description RowTopPartitionTracker.TombstoneCounter. applyToRow(Row row) -
Uses of Row in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type Row Modifier and Type Method Description static PagingState.RowMarkPagingState.RowMark. create(TableMetadata metadata, Row row, ProtocolVersion protocolVersion)protected voidPartitionRangeQueryPager. recordLast(DecoratedKey key, Row last)protected voidSinglePartitionPager. recordLast(DecoratedKey key, Row last) -
Uses of Row in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type Row Modifier and Type Method Description static Commit.AcceptedPaxosRows. getAccepted(Row row, long purgeBefore, long overrideTtlSeconds)static Commit.CommittedPaxosRows. getCommitted(TableMetadata metadata, DecoratedKey partitionKey, Row row, long purgeBefore, long overrideTtlSeconds)static BallotPaxosRows. getHighBallot(Row row, Ballot current)static BallotPaxosRows. getPromise(Row row)static TableIdPaxosRows. getTableId(Row row)static java.util.UUIDPaxosRows. getTableUuid(Row row)static BallotPaxosRows. getWritePromise(Row row)static booleanPaxosRows. hasBallotBeforeOrEqualTo(Row row, Ballot ballot)voidPaxosBallotTracker. onUpdate(Row row) -
Uses of Row in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair that return Row Modifier and Type Method Description RowRowIteratorMergeListener. onMergedRows(Row merged, Row[] versions)Methods in org.apache.cassandra.service.reads.repair with parameters of type Row Modifier and Type Method Description RowRowIteratorMergeListener. onMergedRows(Row merged, Row[] versions) -
Uses of Row in org.apache.cassandra.utils.memory
Methods in org.apache.cassandra.utils.memory that return Row Modifier and Type Method Description abstract RowEnsureOnHeap. applyToRow(Row row)abstract RowEnsureOnHeap. applyToStatic(Row row)Methods in org.apache.cassandra.utils.memory that return types with arguments of type Row Modifier and Type Method Description abstract java.util.Iterator<Row>EnsureOnHeap. applyToPartition(java.util.Iterator<Row> partition)abstract SearchIterator<Clustering<?>,Row>EnsureOnHeap. applyToPartition(SearchIterator<Clustering<?>,Row> partition)Methods in org.apache.cassandra.utils.memory with parameters of type Row Modifier and Type Method Description abstract RowEnsureOnHeap. applyToRow(Row row)abstract RowEnsureOnHeap. applyToStatic(Row row)Method parameters in org.apache.cassandra.utils.memory with type arguments of type Row Modifier and Type Method Description abstract java.util.Iterator<Row>EnsureOnHeap. applyToPartition(java.util.Iterator<Row> partition)abstract SearchIterator<Clustering<?>,Row>EnsureOnHeap. applyToPartition(SearchIterator<Clustering<?>,Row> partition)
-