Modifier and Type | Method and Description |
---|---|
static CounterCacheKey |
CounterCacheKey.create(TableMetadata tableMetadata,
java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
ColumnMetadata c,
CellPath path) |
Modifier and Type | Field and Description |
---|---|
ColumnMetadata |
Operation.column |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<ColumnMetadata> |
MultiColumnRelation.receivers(TableMetadata table) |
Modifier and Type | Method and Description |
---|---|
void |
UpdateParameters.addCell(ColumnMetadata column,
java.nio.ByteBuffer value) |
void |
UpdateParameters.addCell(ColumnMetadata column,
CellPath path,
java.nio.ByteBuffer value) |
void |
UpdateParameters.addCounter(ColumnMetadata column,
long increment) |
void |
UpdateParameters.addTombstone(ColumnMetadata column) |
void |
UpdateParameters.addTombstone(ColumnMetadata column,
CellPath path) |
abstract Term.Raw |
Json.Prepared.getRawTermForColumn(ColumnMetadata def,
boolean defaultUnset) |
Operation |
Operation.RawDeletion.prepare(java.lang.String keyspace,
ColumnMetadata receiver,
TableMetadata metadata)
This method validates the operation (i.e.
|
Operation |
Operation.ColumnDeletion.prepare(java.lang.String keyspace,
ColumnMetadata receiver,
TableMetadata metadata) |
Operation |
Operation.ElementDeletion.prepare(java.lang.String keyspace,
ColumnMetadata receiver,
TableMetadata metadata) |
Operation |
Operation.FieldDeletion.prepare(java.lang.String keyspace,
ColumnMetadata receiver,
TableMetadata metadata) |
Operation |
Operation.RawUpdate.prepare(TableMetadata metadata,
ColumnMetadata receiver)
This method validates the operation (i.e.
|
Operation |
Operation.SetValue.prepare(TableMetadata metadata,
ColumnMetadata receiver) |
Operation |
Operation.SetElement.prepare(TableMetadata metadata,
ColumnMetadata receiver) |
Operation |
Operation.SetField.prepare(TableMetadata metadata,
ColumnMetadata receiver) |
Operation |
Operation.Addition.prepare(TableMetadata metadata,
ColumnMetadata receiver) |
Operation |
Operation.Substraction.prepare(TableMetadata metadata,
ColumnMetadata receiver) |
Operation |
Operation.Prepend.prepare(TableMetadata metadata,
ColumnMetadata receiver) |
void |
UpdateParameters.setComplexDeletionTime(ColumnMetadata column) |
void |
UpdateParameters.setComplexDeletionTimeForOverwrite(ColumnMetadata column) |
Modifier and Type | Method and Description |
---|---|
Term |
QueryOptions.getJsonColumnValue(int bindIndex,
ColumnIdentifier columnName,
java.util.Collection<ColumnMetadata> expectedReceivers)
Returns the term corresponding to column
columnName in the JSON value of bind index bindIndex . |
static java.util.Map<ColumnIdentifier,Term> |
Json.parseJson(java.lang.String jsonString,
java.util.Collection<ColumnMetadata> expectedReceivers)
Given a JSON string, return a map of columns to their values for the insert.
|
Json.Prepared |
Json.Raw.prepareAndCollectMarkers(TableMetadata metadata,
java.util.Collection<ColumnMetadata> receivers,
VariableSpecifications boundNames) |
Json.Prepared |
Json.Literal.prepareAndCollectMarkers(TableMetadata metadata,
java.util.Collection<ColumnMetadata> receivers,
VariableSpecifications boundNames) |
Json.Prepared |
Json.Marker.prepareAndCollectMarkers(TableMetadata metadata,
java.util.Collection<ColumnMetadata> receivers,
VariableSpecifications boundNames) |
Modifier and Type | Field and Description |
---|---|
ColumnMetadata |
ColumnCondition.column |
ColumnMetadata |
ColumnCondition.Bound.column |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ColumnMetadata> |
ColumnConditions.getColumns() |
java.lang.Iterable<ColumnMetadata> |
Conditions.getColumns()
Returns the column definitions to which apply the conditions.
|
Modifier and Type | Method and Description |
---|---|
static ColumnCondition |
ColumnCondition.condition(ColumnMetadata column,
FieldIdentifier udtField,
Operator op,
Terms terms)
A UDT column, simple condition.
|
static ColumnCondition |
ColumnCondition.condition(ColumnMetadata column,
Operator op,
Terms terms)
A regular column, simple condition.
|
static ColumnCondition |
ColumnCondition.condition(ColumnMetadata column,
Term collectionElement,
Operator op,
Terms terms)
A collection column, simple condition.
|
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) |
ColumnCondition |
ColumnCondition.Raw.prepare(java.lang.String keyspace,
ColumnMetadata receiver,
TableMetadata cfm) |
Constructor and Description |
---|
Bound(ColumnMetadata column,
Operator operator) |
Modifier and Type | Field and Description |
---|---|
protected ColumnMetadata |
SingleColumnRestriction.columnDef
The definition of the column to which apply the restriction.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<ColumnMetadata> |
MultiColumnRestriction.columnDefs
The columns to which the restriction apply.
|
protected java.util.List<ColumnMetadata> |
TokenRestriction.columnDefs
The definition of the columns to which apply the token restriction.
|
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
MultiColumnRestriction.getFirstColumn() |
ColumnMetadata |
Restriction.getFirstColumn()
Returns the definition of the first column.
|
ColumnMetadata |
SingleColumnRestriction.getFirstColumn() |
ColumnMetadata |
TokenRestriction.getFirstColumn() |
ColumnMetadata |
MultiColumnRestriction.getLastColumn() |
ColumnMetadata |
Restriction.getLastColumn()
Returns the definition of the last column.
|
ColumnMetadata |
SingleColumnRestriction.getLastColumn() |
ColumnMetadata |
TokenRestriction.getLastColumn() |
Modifier and Type | Method and Description |
---|---|
java.util.List<ColumnMetadata> |
MultiColumnRestriction.getColumnDefs() |
java.util.List<ColumnMetadata> |
Restriction.getColumnDefs()
Returns the column definitions in position order.
|
java.util.List<ColumnMetadata> |
SingleColumnRestriction.getColumnDefs() |
java.util.List<ColumnMetadata> |
TokenRestriction.getColumnDefs() |
java.util.Set<ColumnMetadata> |
StatementRestrictions.nonPKRestrictedColumns(boolean includeNotNullRestrictions)
Returns the non-PK column that are restricted.
|
java.util.Set<ColumnMetadata> |
StatementRestrictions.notNullColumns() |
Modifier and Type | Method and Description |
---|---|
java.util.Set<Restriction> |
Restrictions.getRestrictions(ColumnMetadata columnDef)
Returns the restrictions applied to the specified column.
|
java.util.Set<Restriction> |
TokenRestriction.getRestrictions(ColumnMetadata columnDef) |
boolean |
StatementRestrictions.isColumnRestrictedByEq(ColumnMetadata columnDef)
Checks if the specified column is restricted by an EQ restriction.
|
boolean |
StatementRestrictions.isRestricted(ColumnMetadata column) |
Constructor and Description |
---|
ContainsRestriction(ColumnMetadata columnDef,
Term t,
boolean isKey) |
ContainsRestriction(ColumnMetadata columnDef,
Term mapKey,
Term mapValue) |
EQRestriction(ColumnMetadata columnDef,
Term value) |
INRestriction(ColumnMetadata columnDef) |
InRestrictionWithMarker(ColumnMetadata columnDef,
AbstractMarker marker) |
InRestrictionWithValues(ColumnMetadata columnDef,
java.util.List<Term> values) |
IsNotNullRestriction(ColumnMetadata columnDef) |
LikeRestriction(ColumnMetadata columnDef,
Operator operator,
Term value) |
SingleColumnRestriction(ColumnMetadata columnDef) |
SliceRestriction(ColumnMetadata columnDef,
Bound bound,
boolean inclusive,
Term term) |
Constructor and Description |
---|
EQRestriction(java.util.List<ColumnMetadata> columnDefs,
Term value) |
EQRestriction(TableMetadata table,
java.util.List<ColumnMetadata> columnDefs,
Term value) |
INRestriction(java.util.List<ColumnMetadata> columnDefs) |
InRestrictionWithMarker(java.util.List<ColumnMetadata> columnDefs,
AbstractMarker marker) |
InRestrictionWithValues(java.util.List<ColumnMetadata> columnDefs,
java.util.List<Term> values) |
MultiColumnRestriction(java.util.List<ColumnMetadata> columnDefs) |
NotNullRestriction(java.util.List<ColumnMetadata> columnDefs) |
SliceRestriction(java.util.List<ColumnMetadata> columnDefs,
Bound bound,
boolean inclusive,
Term term) |
SliceRestriction(TableMetadata table,
java.util.List<ColumnMetadata> columnDefs,
Bound bound,
boolean inclusive,
Term term) |
TokenRestriction(TableMetadata metadata,
java.util.List<ColumnMetadata> columnDefs)
Creates a new
TokenRestriction that apply to the specified columns. |
Modifier and Type | Field and Description |
---|---|
ColumnMetadata |
Selectable.WritetimeOrTTL.column |
ColumnMetadata |
SimpleSelector.column |
Modifier and Type | Field and Description |
---|---|
protected java.util.List<ColumnMetadata> |
Selection.orderingColumns |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
SimpleSelector.SimpleSelectorFactory.getColumn() |
ColumnMetadata |
Selectable.RawIdentifier.prepare(TableMetadata cfm) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ColumnMetadata> |
Selection.getColumns() |
com.google.common.collect.Multimap<ColumnSpecification,ColumnMetadata> |
SelectionColumnMapping.getMappings() |
com.google.common.collect.Multimap<ColumnSpecification,ColumnMetadata> |
SelectionColumns.getMappings() |
Modifier and Type | Method and Description |
---|---|
default int |
Selectable.addAndGetIndex(ColumnMetadata def,
java.util.List<ColumnMetadata> l) |
protected SelectionColumnMapping |
SelectionColumnMapping.addMapping(ColumnSpecification colSpec,
ColumnMetadata column) |
protected int |
Selection.getColumnIndex(ColumnMetadata c)
Returns the index of the specified column
|
java.lang.Integer |
Selection.getOrderingIndex(ColumnMetadata c)
Returns the corresponding column index used for post query ordering
|
int |
Selection.getResultSetIndex(ColumnMetadata c)
Returns the index of the specified column within the resultset
|
static Selector.Factory |
SimpleSelector.newFactory(ColumnMetadata def,
int idx) |
Modifier and Type | Method and Description |
---|---|
default int |
Selectable.addAndGetIndex(ColumnMetadata def,
java.util.List<ColumnMetadata> l) |
protected SelectionColumnMapping |
SelectionColumnMapping.addMapping(ColumnSpecification colSpec,
java.lang.Iterable<ColumnMetadata> columns) |
static Selection |
Selection.forColumns(TableMetadata table,
java.util.List<ColumnMetadata> columns,
boolean returnStaticContentOnPartitionWithNoRows) |
static Selection |
Selection.fromSelectors(TableMetadata table,
java.util.List<Selectable> selectables,
VariableSpecifications boundNames,
java.util.Set<ColumnMetadata> orderingColumns,
java.util.Set<ColumnMetadata> nonPKRestrictedColumns,
boolean hasGroupBy,
boolean isJson,
boolean returnStaticContentOnPartitionWithNoRows) |
static Selection |
Selection.fromSelectors(TableMetadata table,
java.util.List<Selectable> selectables,
VariableSpecifications boundNames,
java.util.Set<ColumnMetadata> orderingColumns,
java.util.Set<ColumnMetadata> nonPKRestrictedColumns,
boolean hasGroupBy,
boolean isJson,
boolean returnStaticContentOnPartitionWithNoRows) |
Selector.Factory |
Selectable.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithTerm.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WritetimeOrTTL.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithFunction.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithToJSonFunction.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithCast.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithFieldSelection.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.BetweenParenthesesOrWithTuple.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithList.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithSet.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithMapOrUdt.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithTypeHint.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithElementSelection.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
Selector.Factory |
Selectable.WithSliceSelection.newSelectorFactory(TableMetadata cfm,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
static boolean |
Selectable.selectColumns(java.util.List<Selectable> selectables,
java.util.function.Predicate<ColumnMetadata> predicate)
Checks if the specified Selectables select columns matching the specified predicate.
|
boolean |
Selectable.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate)
Checks if this
Selectable select columns matching the specified predicate. |
boolean |
Selectable.WithTerm.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WritetimeOrTTL.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithFunction.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithToJSonFunction.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithCast.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithFieldSelection.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.BetweenParenthesesOrWithTuple.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithList.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithSet.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithMapOrUdt.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithTypeHint.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithElementSelection.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
boolean |
Selectable.WithSliceSelection.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
protected static SelectionColumnMapping |
SelectionColumnMapping.simpleMapping(java.lang.Iterable<ColumnMetadata> columnDefinitions) |
Constructor and Description |
---|
WritetimeOrTTL(ColumnMetadata column,
boolean isWritetime) |
Constructor and Description |
---|
Selection(TableMetadata table,
java.util.List<ColumnMetadata> selectedColumns,
java.util.Set<ColumnMetadata> orderingColumns,
SelectionColumnMapping columnMapping,
org.apache.cassandra.cql3.selection.ColumnFilterFactory columnFilterFactory,
boolean isJson) |
Selection(TableMetadata table,
java.util.List<ColumnMetadata> selectedColumns,
java.util.Set<ColumnMetadata> orderingColumns,
SelectionColumnMapping columnMapping,
org.apache.cassandra.cql3.selection.ColumnFilterFactory columnFilterFactory,
boolean isJson) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<ColumnMetadata> |
ModificationStatement.getColumnsWithConditions() |
Modifier and Type | Method and Description |
---|---|
Bound |
Bound.reverseIfNeeded(ColumnMetadata columnMetadata)
Reverses the bound if the column type is a reversed one.
|
Modifier and Type | Field and Description |
---|---|
static ColumnMetadata |
Columns.FIRST_COMPLEX_REGULAR |
static ColumnMetadata |
Columns.FIRST_COMPLEX_STATIC |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
Columns.getComplex(int i)
Returns the ith complex column of this object.
|
ColumnMetadata |
Columns.getSimple(int i)
Returns the ith simple column of this object.
|
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<ColumnMetadata> |
Columns.complexColumns()
Iterator over the complex columns of this object.
|
java.util.function.Predicate<ColumnMetadata> |
Columns.inOrderInclusionTester()
Returns a predicate to test whether columns are included in this
Columns object,
assuming that tes tested columns are passed to the predicate in sorted order. |
BTreeSearchIterator<ColumnMetadata,ColumnMetadata> |
Columns.iterator()
Iterator over all the columns of this object.
|
BTreeSearchIterator<ColumnMetadata,ColumnMetadata> |
Columns.iterator()
Iterator over all the columns of this object.
|
java.util.Iterator<ColumnMetadata> |
RegularAndStaticColumns.iterator() |
java.util.Iterator<ColumnMetadata> |
Columns.selectOrderIterator()
An iterator that returns the columns of this object in "select" order (that
is in global alphabetical order, where the "normal" iterator returns simple
columns first and the complex second).
|
java.util.Iterator<ColumnMetadata> |
RegularAndStaticColumns.selectOrderIterator() |
java.util.Iterator<ColumnMetadata> |
Columns.simpleColumns()
Iterator over the simple columns of this object.
|
Modifier and Type | Method and Description |
---|---|
RegularAndStaticColumns.Builder |
RegularAndStaticColumns.Builder.add(ColumnMetadata c) |
int |
Columns.complexIdx(ColumnMetadata c)
The index of the provided complex column in this object (if it contains
the provided column).
|
boolean |
Columns.contains(ColumnMetadata c)
Whether the provided column is contained by this object.
|
boolean |
RegularAndStaticColumns.contains(ColumnMetadata column) |
ClockAndCount |
ColumnFamilyStore.getCachedCounter(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
ColumnMetadata column,
CellPath path) |
AbstractType<?> |
SerializationHeader.getType(ColumnMetadata column) |
static Columns |
Columns.of(ColumnMetadata c)
Creates a
Columns holding only the one column provided. |
static RegularAndStaticColumns |
RegularAndStaticColumns.of(ColumnMetadata column) |
void |
ColumnFamilyStore.putCachedCounter(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
ColumnMetadata column,
CellPath path,
ClockAndCount clockAndCount) |
int |
Columns.simpleIdx(ColumnMetadata c)
The index of the provided simple column in this object (if it contains
the provided column).
|
Columns |
Columns.without(ColumnMetadata column)
Returns the equivalent of those columns but with the provided column removed.
|
RegularAndStaticColumns |
RegularAndStaticColumns.without(ColumnMetadata column) |
Modifier and Type | Method and Description |
---|---|
RegularAndStaticColumns.Builder |
RegularAndStaticColumns.Builder.addAll(java.lang.Iterable<ColumnMetadata> columns) |
void |
Columns.apply(java.util.function.Consumer<ColumnMetadata> function)
Apply a function to each column definition in forwards or reversed order.
|
abstract java.util.NavigableSet<ClusteringBound<?>> |
MultiCBuilder.buildBoundForSlice(boolean isStart,
boolean isInclusive,
boolean isOtherBoundInclusive,
java.util.List<ColumnMetadata> columnDefs)
Builds the
ClusteringBound s for slice restrictions. |
static Columns |
Columns.from(BTree.Builder<ColumnMetadata> builder) |
static Columns |
Columns.from(java.util.Collection<ColumnMetadata> s)
Returns a new
Columns object holding the same columns than the provided set. |
long |
Columns.Serializer.serializedSubsetSize(java.util.Collection<ColumnMetadata> columns,
Columns superset) |
void |
Columns.Serializer.serializeSubset(java.util.Collection<ColumnMetadata> columns,
Columns superset,
DataOutputPlus out)
If both ends have a pre-shared superset of the columns we are serializing, we can send them much
more efficiently.
|
Modifier and Type | Field and Description |
---|---|
protected ColumnMetadata |
ColumnSubselection.column |
protected ColumnMetadata |
RowFilter.Expression.column |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
ColumnSubselection.column() |
ColumnMetadata |
RowFilter.Expression.column() |
Modifier and Type | Method and Description |
---|---|
ColumnFilter.Builder |
ColumnFilter.Builder.add(ColumnMetadata c) |
RowFilter.SimpleExpression |
RowFilter.add(ColumnMetadata def,
Operator op,
java.nio.ByteBuffer value) |
void |
RowFilter.addMapEquality(ColumnMetadata def,
java.nio.ByteBuffer key,
Operator op,
java.nio.ByteBuffer value) |
static ColumnSubselection |
ColumnSubselection.element(ColumnMetadata column,
CellPath elt) |
abstract boolean |
ColumnFilter.fetchedCellIsQueried(ColumnMetadata column,
CellPath path)
Whether the provided complex cell (identified by its column and path), which is assumed to be _fetched_ by
this filter, is also _queried_ by the user.
|
boolean |
ColumnFilter.WildCardColumnFilter.fetchedCellIsQueried(ColumnMetadata column,
CellPath path) |
boolean |
ColumnFilter.SelectionColumnFilter.fetchedCellIsQueried(ColumnMetadata column,
CellPath path) |
abstract boolean |
ColumnFilter.fetchedColumnIsQueried(ColumnMetadata column)
Whether the provided column, which is assumed to be _fetched_ by this filter (so the caller must guarantee
that
fetches(column) == true , is also _queried_ by the user. |
boolean |
ColumnFilter.WildCardColumnFilter.fetchedColumnIsQueried(ColumnMetadata column) |
boolean |
ColumnFilter.SelectionColumnFilter.fetchedColumnIsQueried(ColumnMetadata column)
Whether the provided complex cell (identified by its column and path), which is assumed to be _fetched_ by
this filter, is also _queried_ by the user.
|
abstract boolean |
ColumnFilter.fetches(ColumnMetadata column)
Whether the provided column is fetched by this filter.
|
boolean |
ColumnFilter.WildCardColumnFilter.fetches(ColumnMetadata column) |
boolean |
ColumnFilter.SelectionColumnFilter.fetches(ColumnMetadata column) |
abstract ColumnFilter.Tester |
ColumnFilter.newTester(ColumnMetadata column)
Creates a new
Tester to efficiently test the inclusion of cells of complex column
column . |
ColumnFilter.Tester |
ColumnFilter.WildCardColumnFilter.newTester(ColumnMetadata column) |
ColumnFilter.Tester |
ColumnFilter.SelectionColumnFilter.newTester(ColumnMetadata column) |
ColumnFilter.Builder |
ColumnFilter.Builder.select(ColumnMetadata c,
CellPath elt) |
ColumnFilter.Builder |
ColumnFilter.Builder.slice(ColumnMetadata c,
CellPath from,
CellPath to) |
static ColumnSubselection |
ColumnSubselection.slice(ColumnMetadata column,
CellPath from,
CellPath to) |
Modifier and Type | Method and Description |
---|---|
ColumnFilter.Builder |
ColumnFilter.Builder.addAll(java.lang.Iterable<ColumnMetadata> columns) |
Constructor and Description |
---|
ColumnSubselection(ColumnMetadata column) |
Expression(ColumnMetadata column,
Operator operator,
java.nio.ByteBuffer value) |
UserExpression(ColumnMetadata column,
Operator operator,
java.nio.ByteBuffer value) |
Modifier and Type | Method and Description |
---|---|
Cell<V> |
ValueAccessor.ObjectFactory.cell(ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
V value,
CellPath path) |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
PartitionUpdate.CounterMark.column() |
Modifier and Type | Field and Description |
---|---|
protected ColumnMetadata |
ColumnData.column |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
ColumnData.column()
The column this is data for.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ColumnMetadata> |
BTreeRow.columns() |
java.util.Collection<ColumnMetadata> |
Row.columns()
An in-natural-order collection of the columns for which data (incl.
|
SearchIterator<ColumnMetadata,ColumnMetadata> |
SerializationHelper.iterator(boolean isStatic) |
SearchIterator<ColumnMetadata,ColumnMetadata> |
SerializationHelper.iterator(boolean isStatic) |
BTreeSearchIterator<ColumnMetadata,ColumnData> |
BTreeRow.searchIterator() |
SearchIterator<ColumnMetadata,ColumnData> |
Row.searchIterator()
An iterator to efficiently search data for a given column.
|
Modifier and Type | Method and Description |
---|---|
void |
BTreeRow.Builder.addComplexDeletion(ColumnMetadata column,
DeletionTime complexDeletion) |
void |
Row.Builder.addComplexDeletion(ColumnMetadata column,
DeletionTime complexDeletion)
Adds a complex deletion.
|
static void |
Cells.addNonShadowedComplex(ColumnMetadata column,
java.util.Iterator<Cell<?>> existing,
java.util.Iterator<Cell<?>> update,
DeletionTime deletion,
Row.Builder builder)
Adds to the builder a representation of the given existing cell that, when merged/reconciled with the given
update cell, produces the same result as merging the original with the update.
|
boolean |
DeserializationHelper.canSkipValue(ColumnMetadata column) |
Cell<V> |
Cell.Factory.create(ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
V value,
CellPath path) |
static BufferCell |
BufferCell.expiring(ColumnMetadata column,
long timestamp,
int ttl,
int nowInSec,
java.nio.ByteBuffer value) |
static BufferCell |
BufferCell.expiring(ColumnMetadata column,
long timestamp,
int ttl,
int nowInSec,
java.nio.ByteBuffer value,
CellPath path) |
Cell<?> |
BTreeRow.getCell(ColumnMetadata c) |
Cell<?> |
Row.getCell(ColumnMetadata c)
Returns a cell for a simple column.
|
Cell<?> |
BTreeRow.getCell(ColumnMetadata c,
CellPath path) |
Cell<?> |
Row.getCell(ColumnMetadata c,
CellPath path)
Return a cell for a given complex column and cell path.
|
ComplexColumnData |
BTreeRow.getComplexColumnData(ColumnMetadata c) |
ComplexColumnData |
Row.getComplexColumnData(ColumnMetadata c)
The data for a complex column.
|
boolean |
DeserializationHelper.includes(ColumnMetadata column) |
static BufferCell |
BufferCell.live(ColumnMetadata column,
long timestamp,
java.nio.ByteBuffer value) |
static BufferCell |
BufferCell.live(ColumnMetadata column,
long timestamp,
java.nio.ByteBuffer value,
CellPath path) |
void |
ComplexColumnData.Builder.newColumn(ColumnMetadata column) |
void |
RowDiffListener.onComplexDeletion(int i,
Clustering<?> clustering,
ColumnMetadata column,
DeletionTime merged,
DeletionTime original)
Called for every (non-live) complex deletion of any complex column present in either the merged row of input
i . |
void |
BTreeRow.setValue(ColumnMetadata column,
CellPath path,
java.nio.ByteBuffer value) |
void |
DeserializationHelper.startOfComplexColumn(ColumnMetadata column) |
static BufferCell |
BufferCell.tombstone(ColumnMetadata column,
long timestamp,
int nowInSec) |
static BufferCell |
BufferCell.tombstone(ColumnMetadata column,
long timestamp,
int nowInSec,
CellPath path) |
static ComplexColumnData |
ComplexColumnData.unsafeConstruct(ColumnMetadata column,
java.lang.Object[] cells,
DeletionTime complexDeletion) |
Cell<?> |
ArrayCell.withUpdatedColumn(ColumnMetadata newColumn) |
Cell<?> |
BufferCell.withUpdatedColumn(ColumnMetadata newColumn) |
abstract Cell<?> |
Cell.withUpdatedColumn(ColumnMetadata newColumn) |
Cell<?> |
NativeCell.withUpdatedColumn(ColumnMetadata column) |
Constructor and Description |
---|
AbstractCell(ColumnMetadata column) |
ArrayCell(ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
byte[] value,
CellPath path) |
BufferCell(ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
java.nio.ByteBuffer value,
CellPath path) |
Cell(ColumnMetadata column) |
ColumnData(ColumnMetadata column) |
NativeCell(NativeAllocator allocator,
OpOrder.Group writeOp,
ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
java.nio.ByteBuffer value,
CellPath path) |
Modifier and Type | Field and Description |
---|---|
java.util.List<ColumnMetadata> |
View.baseNonPKColumnsInViewPK |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
View.getBaseColumn(ColumnMetadata viewColumn)
The base column corresponding to the provided view column.
|
ColumnMetadata |
View.getViewColumn(ColumnMetadata baseColumn)
The view column corresponding to the provided base column.
|
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
View.getBaseColumn(ColumnMetadata viewColumn)
The base column corresponding to the provided view column.
|
ColumnMetadata |
View.getViewColumn(ColumnMetadata baseColumn)
The view column corresponding to the provided base column.
|
Modifier and Type | Method and Description |
---|---|
static Pair<ColumnMetadata,IndexTarget.Type> |
TargetParser.parse(TableMetadata metadata,
IndexMetadata indexDef) |
static Pair<ColumnMetadata,IndexTarget.Type> |
TargetParser.parse(TableMetadata metadata,
java.lang.String target) |
Modifier and Type | Method and Description |
---|---|
boolean |
Index.dependsOn(ColumnMetadata column)
Called to determine whether this index targets a specific column.
|
java.util.Set<IndexMetadata> |
SecondaryIndexManager.getDependentIndexes(ColumnMetadata column) |
boolean |
Index.supportsExpression(ColumnMetadata column,
Operator operator)
Called to determine whether this index can provide a searcher to execute a query on the
supplied column using the specified operator.
|
Modifier and Type | Field and Description |
---|---|
protected ColumnMetadata |
CassandraIndex.indexedColumn |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
CassandraIndex.getIndexedColumn() |
Modifier and Type | Method and Description |
---|---|
default TableMetadata.Builder |
CassandraIndexFunctions.addIndexClusteringColumns(TableMetadata.Builder builder,
TableMetadata baseMetadata,
ColumnMetadata cfDef)
Add the clustering columns for a specific type of index table to the a TableMetadata.Builder (which is being
used to construct the index table's TableMetadata.
|
boolean |
CassandraIndex.dependsOn(ColumnMetadata column) |
default AbstractType<?> |
CassandraIndexFunctions.getIndexedValueType(ColumnMetadata indexedColumn)
Returns the type of the the values in the index.
|
boolean |
CassandraIndex.supportsExpression(ColumnMetadata column,
Operator operator) |
protected boolean |
CassandraIndex.supportsOperator(ColumnMetadata indexedColumn,
Operator operator)
Returns true if an index of this type can support search predicates of the form [column] OPERATOR [value]
|
Modifier and Type | Method and Description |
---|---|
boolean |
CollectionKeyIndex.supportsOperator(ColumnMetadata indexedColumn,
Operator operator) |
boolean |
CollectionValueIndex.supportsOperator(ColumnMetadata indexedColumn,
Operator operator) |
Modifier and Type | Method and Description |
---|---|
TableMetadata.Builder |
KeysIndex.addIndexClusteringColumns(TableMetadata.Builder builder,
TableMetadataRef baseMetadata,
ColumnMetadata cfDef) |
Modifier and Type | Method and Description |
---|---|
boolean |
SASIIndex.dependsOn(ColumnMetadata column) |
boolean |
SASIIndex.supportsExpression(ColumnMetadata column,
Operator operator) |
Modifier and Type | Method and Description |
---|---|
protected static PerSSTableIndexWriter |
SASIIndex.newWriter(AbstractType<?> keyValidator,
Descriptor descriptor,
java.util.Map<ColumnMetadata,ColumnIndex> indexes,
OperationType opType) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractAnalyzer.validate(java.util.Map<java.lang.String,java.lang.String> options,
ColumnMetadata cm) |
void |
NonTokenizingAnalyzer.validate(java.util.Map<java.lang.String,java.lang.String> options,
ColumnMetadata cm) |
Modifier and Type | Method and Description |
---|---|
ColumnMetadata |
ColumnIndex.getDefinition() |
Modifier and Type | Method and Description |
---|---|
static IndexMode |
IndexMode.getMode(ColumnMetadata column,
java.util.Map<java.lang.String,java.lang.String> indexOptions) |
static IndexMode |
IndexMode.getMode(ColumnMetadata column,
java.util.Optional<IndexMetadata> config) |
static java.nio.ByteBuffer |
ColumnIndex.getValueOf(ColumnMetadata column,
Row row,
int nowInSecs) |
static void |
IndexMode.validateAnalyzer(java.util.Map<java.lang.String,java.lang.String> indexOptions,
ColumnMetadata cd) |
Constructor and Description |
---|
ColumnIndex(AbstractType<?> keyValidator,
ColumnMetadata column,
IndexMetadata metadata) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<ColumnMetadata,PerSSTableIndexWriter.Index> |
PerSSTableIndexWriter.indexes |
Modifier and Type | Method and Description |
---|---|
PerSSTableIndexWriter.Index |
PerSSTableIndexWriter.getIndex(ColumnMetadata columnDef) |
Constructor and Description |
---|
PerSSTableIndexWriter(AbstractType<?> keyValidator,
Descriptor descriptor,
OperationType source,
java.util.Map<ColumnMetadata,ColumnIndex> supportedIndexes) |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.collect.ListMultimap<ColumnMetadata,Expression> |
Operation.expressions |
Modifier and Type | Method and Description |
---|---|
protected static com.google.common.collect.ListMultimap<ColumnMetadata,Expression> |
Operation.analyzeGroup(QueryController controller,
Operation.OperationType op,
java.util.List<RowFilter.Expression> expressions) |
Modifier and Type | Field and Description |
---|---|
ColumnMetadata |
DroppedColumn.column |
ColumnMetadata |
TableMetadata.CompactTableMetadata.compactValueColumn |
Modifier and Type | Field and Description |
---|---|
protected com.google.common.collect.ImmutableList<ColumnMetadata> |
TableMetadata.clusteringColumns |
protected com.google.common.collect.ImmutableList<ColumnMetadata> |
TableMetadata.partitionKeyColumns |
Modifier and Type | Method and Description |
---|---|
static ColumnMetadata |
ColumnMetadata.clusteringColumn(java.lang.String keyspace,
java.lang.String table,
java.lang.String name,
AbstractType<?> type,
int position) |
static ColumnMetadata |
ColumnMetadata.clusteringColumn(TableMetadata table,
java.nio.ByteBuffer name,
AbstractType<?> type,
int position) |
ColumnMetadata |
ColumnMetadata.copy() |
ColumnMetadata |
TableMetadata.getColumn(java.nio.ByteBuffer name) |
ColumnMetadata |
TableMetadata.Builder.getColumn(java.nio.ByteBuffer name) |
ColumnMetadata |
TableMetadata.getColumn(ColumnIdentifier name)
Returns the ColumnMetadata for
name . |
ColumnMetadata |
TableMetadata.Builder.getColumn(ColumnIdentifier identifier) |
static ColumnMetadata |
TableMetadata.CompactTableMetadata.getCompactValueColumn(RegularAndStaticColumns columns) |
ColumnMetadata |
TableMetadata.getDroppedColumn(java.nio.ByteBuffer name) |
ColumnMetadata |
TableMetadata.getDroppedColumn(java.nio.ByteBuffer name,
boolean isStatic)
Returns a "fake" ColumnMetadata corresponding to the dropped column
name
of null if there is no such dropped column. |
ColumnMetadata |
TableMetadata.getExistingColumn(ColumnIdentifier name)
Returns the column of the provided name if it exists, but throws a user-visible exception if that column doesn't
exist.
|
ColumnMetadata |
TableMetadata.CompactTableMetadata.getExistingColumn(ColumnIdentifier name) |
static ColumnMetadata |
ColumnMetadata.partitionKeyColumn(java.lang.String keyspace,
java.lang.String table,
java.lang.String name,
AbstractType<?> type,
int position) |
static ColumnMetadata |
ColumnMetadata.partitionKeyColumn(TableMetadata table,
java.nio.ByteBuffer name,
AbstractType<?> type,
int position) |
static ColumnMetadata |
ColumnMetadata.regularColumn(java.lang.String keyspace,
java.lang.String table,
java.lang.String name,
AbstractType<?> type) |
static ColumnMetadata |
ColumnMetadata.regularColumn(TableMetadata table,
java.nio.ByteBuffer name,
AbstractType<?> type) |
static ColumnMetadata |
ColumnMetadata.staticColumn(java.lang.String keyspace,
java.lang.String table,
java.lang.String name,
AbstractType<?> type) |
static ColumnMetadata |
ColumnMetadata.staticColumn(TableMetadata table,
java.nio.ByteBuffer name,
AbstractType<?> type) |
ColumnMetadata |
ColumnMetadata.withNewName(ColumnIdentifier newName) |
ColumnMetadata |
ColumnMetadata.withNewType(AbstractType<?> newType) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<ColumnMetadata> |
TableMetadata.allColumnsInCreateOrder()
Returns an iterator over all column definitions that respect the order of the CREATE statement.
|
java.util.Iterator<ColumnMetadata> |
TableMetadata.CompactTableMetadata.allColumnsInCreateOrder() |
java.util.Iterator<ColumnMetadata> |
TableMetadata.allColumnsInSelectOrder() |
java.util.Iterator<ColumnMetadata> |
TableMetadata.CompactTableMetadata.allColumnsInSelectOrder() |
com.google.common.collect.ImmutableList<ColumnMetadata> |
TableMetadata.clusteringColumns() |
com.google.common.collect.ImmutableCollection<ColumnMetadata> |
TableMetadata.columns() |
java.lang.Iterable<ColumnMetadata> |
TableMetadata.Builder.columns() |
com.google.common.collect.ImmutableList<ColumnMetadata> |
TableMetadata.CompactTableMetadata.createStatementClusteringColumns() |
com.google.common.collect.ImmutableList<ColumnMetadata> |
TableMetadata.partitionKeyColumns() |
java.lang.Iterable<ColumnMetadata> |
TableMetadata.primaryKeyColumns() |
Modifier and Type | Method and Description |
---|---|
TableMetadata.Builder |
TableMetadata.Builder.addColumn(ColumnMetadata column) |
int |
ColumnMetadata.compareTo(ColumnMetadata other) |
boolean |
TableMetadata.CompactTableMetadata.isHiddenColumn(ColumnMetadata def) |
TableMetadata.Builder |
TableMetadata.Builder.recordColumnDrop(ColumnMetadata column,
long timeMicros) |
ViewMetadata |
ViewMetadata.withAddedRegularColumn(ColumnMetadata column) |
Modifier and Type | Method and Description |
---|---|
TableMetadata.Builder |
TableMetadata.Builder.addColumns(java.lang.Iterable<ColumnMetadata> columns) |
Selector.Factory |
ColumnMetadata.newSelectorFactory(TableMetadata table,
AbstractType<?> expectedType,
java.util.List<ColumnMetadata> defs,
VariableSpecifications boundNames) |
boolean |
ColumnMetadata.selectColumns(java.util.function.Predicate<ColumnMetadata> predicate) |
static java.lang.String |
ColumnMetadata.toCQLString(java.lang.Iterable<ColumnMetadata> defs) |
static java.lang.String |
ColumnMetadata.toCQLString(java.util.Iterator<ColumnMetadata> defs) |
static java.util.Collection<ColumnIdentifier> |
ColumnMetadata.toIdentifiers(java.util.Collection<ColumnMetadata> definitions)
Converts the specified column definitions into column identifiers.
|
Constructor and Description |
---|
DroppedColumn(ColumnMetadata column,
long droppedTime) |
Copyright © 2009-2022 The Apache Software Foundation