Modifier and Type | Method and Description |
---|---|
static void |
SuperColumnCompatibility.processPartition(CFMetaData cfm,
Selection selection,
RowIterator partition,
Selection.ResultSetBuilder result,
ProtocolVersion protocolVersion,
SuperColumnCompatibility.SuperColumnRestrictions restrictions,
QueryOptions queryOptions)
For _dense_ SuperColumn Families.
|
static UntypedResultSet |
QueryProcessor.resultify(java.lang.String query,
RowIterator partition) |
Modifier and Type | Method and Description |
---|---|
static ResultSet |
ModificationStatement.buildCasResultSet(java.lang.String ksName,
java.lang.String tableName,
RowIterator partition,
java.lang.Iterable<ColumnDefinition> columnsWithConditions,
boolean isBatch,
QueryOptions options) |
Modifier and Type | Method and Description |
---|---|
static RowIterator |
EmptyIterators.row(CFMetaData metadata,
DecoratedKey partitionKey,
boolean isReverseOrder) |
Modifier and Type | Method and Description |
---|---|
RowIterator |
DataLimits.Counter.applyTo(RowIterator partition) |
Modifier and Type | Method and Description |
---|---|
RowIterator |
DataLimits.Counter.applyTo(RowIterator partition) |
Modifier and Type | Method and Description |
---|---|
static RowIterator |
PartitionIterators.getOnlyElement(PartitionIterator iter,
SinglePartitionReadCommand command) |
RowIterator |
FilteredPartition.rowIterator() |
Modifier and Type | Method and Description |
---|---|
protected static AbstractBTreePartition.Holder |
AbstractBTreePartition.build(RowIterator rows,
DeletionInfo deletion,
boolean buildEncodingStats,
int initialRowCapacity) |
static FilteredPartition |
FilteredPartition.create(RowIterator iterator)
Create a FilteredPartition holding all the rows of the provided iterator.
|
static PartitionUpdate |
PartitionUpdate.fromIterator(RowIterator iterator,
ColumnFilter filter)
Turns the given iterator into an update.
|
static PartitionIterator |
PartitionIterators.singletonIterator(RowIterator iterator) |
Constructor and Description |
---|
FilteredPartition(RowIterator rows) |
Modifier and Type | Method and Description |
---|---|
static RowIterator |
UnfilteredRowIterators.filter(UnfilteredRowIterator iter,
int nowInSec)
Returns a iterator that only returns rows with only live content.
|
static RowIterator |
RowIterators.loggingIterator(RowIterator iterator,
java.lang.String id)
Wraps the provided iterator so it logs the returned rows for debugging purposes.
|
static RowIterator |
RowIterators.withOnlyQueriedData(RowIterator iterator,
ColumnFilter filter)
Filter the provided iterator to only include cells that are selected by the user.
|
Modifier and Type | Method and Description |
---|---|
static void |
RowIterators.digest(RowIterator iterator,
java.security.MessageDigest digest) |
static RowIterator |
RowIterators.loggingIterator(RowIterator iterator,
java.lang.String id)
Wraps the provided iterator so it logs the returned rows for debugging purposes.
|
static RowIterator |
RowIterators.withOnlyQueriedData(RowIterator iterator,
ColumnFilter filter)
Filter the provided iterator to only include cells that are selected by the user.
|
Modifier and Type | Class and Description |
---|---|
class |
FilteredRows |
Modifier and Type | Method and Description |
---|---|
static RowIterator |
Transformation.apply(RowIterator iterator,
Transformation<?> transformation) |
protected RowIterator |
Filter.applyToPartition(BaseRowIterator iterator) |
static RowIterator |
MoreRows.extend(RowIterator iterator,
MoreRows<? super RowIterator> more) |
static RowIterator |
FilteredRows.filter(UnfilteredRowIterator iterator,
int nowInSecs)
Filter any RangeTombstoneMarker from the iterator, transforming it into a RowIterator.
|
Modifier and Type | Method and Description |
---|---|
static RowIterator |
Transformation.apply(RowIterator iterator,
Transformation<?> transformation) |
static RowIterator |
MoreRows.extend(RowIterator iterator,
MoreRows<? super RowIterator> more) |
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
Transformation.apply(PartitionIterator iterator,
Transformation<? super RowIterator> transformation) |
static RowIterator |
MoreRows.extend(RowIterator iterator,
MoreRows<? super RowIterator> more) |
Modifier and Type | Method and Description |
---|---|
protected abstract UnfilteredPartitionIterator |
CassandraIndexSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredPartitionIterator |
CompositesSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
protected UnfilteredPartitionIterator |
KeysSearcher.queryDataFromIndex(DecoratedKey indexKey,
RowIterator indexHits,
ReadCommand command,
ReadExecutionController executionController) |
Modifier and Type | Method and Description |
---|---|
static RowIterator |
StorageProxy.cas(java.lang.String keyspaceName,
java.lang.String cfName,
DecoratedKey key,
CASRequest request,
ConsistencyLevel consistencyForPaxos,
ConsistencyLevel consistencyForCommit,
ClientState state,
long queryStartNanoTime)
Apply @param updates if and only if the current values in the row for @param key
match the provided @param conditions.
|
static RowIterator |
StorageProxy.readOne(SinglePartitionReadCommand command,
ConsistencyLevel consistencyLevel,
ClientState state,
long queryStartNanoTime) |
static RowIterator |
StorageProxy.readOne(SinglePartitionReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
RowIterator |
AggregationQueryPager.GroupByPartitionIterator.next() |
Copyright © 2018 The Apache Software Foundation