/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.cassandra.cql3;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import org.apache.cassandra.cql3.functions.Function;
import org.apache.cassandra.cql3.statements.StatementType;

import com.google.common.collect.Iterators;

A set of Operations.
/** * A set of <code>Operation</code>s. * */
public final class Operations implements Iterable<Operation> {
The type of statement.
/** * The type of statement. */
private final StatementType type;
The operations on regular columns.
/** * The operations on regular columns. */
private final List<Operation> regularOperations = new ArrayList<>();
The operations on static columns.
/** * The operations on static columns. */
private final List<Operation> staticOperations = new ArrayList<>(); public Operations(StatementType type) { this.type = type; }
Checks if some of the operations apply to static columns.
Returns:true if some of the operations apply to static columns, false otherwise.
/** * Checks if some of the operations apply to static columns. * * @return <code>true</code> if some of the operations apply to static columns, <code>false</code> otherwise. */
public boolean appliesToStaticColumns() { return !staticOperations.isEmpty(); }
Checks if some of the operations apply to regular columns.
Returns:true if some of the operations apply to regular columns, false otherwise.
/** * Checks if some of the operations apply to regular columns. * * @return <code>true</code> if some of the operations apply to regular columns, <code>false</code> otherwise. */
public boolean appliesToRegularColumns() { // If we have regular operations, this applies to regular columns. // Otherwise, if the statement is a DELETE and staticOperations is also empty, this means we have no operations, // which for a DELETE means a full row deletion. Which means the operation applies to all columns and regular ones in particular. return !regularOperations.isEmpty() || (type.isDelete() && staticOperations.isEmpty()); }
Returns the operation on regular columns.
Returns:the operation on regular columns
/** * Returns the operation on regular columns. * @return the operation on regular columns */
public List<Operation> regularOperations() { return regularOperations; }
Returns the operation on static columns.
Returns:the operation on static columns
/** * Returns the operation on static columns. * @return the operation on static columns */
public List<Operation> staticOperations() { return staticOperations; }
Adds the specified Operation to this set of operations.
Params:
  • operation – the operation to add
/** * Adds the specified <code>Operation</code> to this set of operations. * @param operation the operation to add */
public void add(Operation operation) { if (operation.column.isStatic()) staticOperations.add(operation); else regularOperations.add(operation); }
Checks if one of the operations requires a read.
Returns:true if one of the operations requires a read, false otherwise.
/** * Checks if one of the operations requires a read. * * @return <code>true</code> if one of the operations requires a read, <code>false</code> otherwise. */
public boolean requiresRead() { // Lists SET operation incurs a read. for (Operation operation : this) if (operation.requiresRead()) return true; return false; }
Checks if this Operations is empty.
Returns:true if this Operations is empty, false otherwise.
/** * Checks if this <code>Operations</code> is empty. * @return <code>true</code> if this <code>Operations</code> is empty, <code>false</code> otherwise. */
public boolean isEmpty() { return staticOperations.isEmpty() && regularOperations.isEmpty(); }
{@inheritDoc}
/** * {@inheritDoc} */
@Override public Iterator<Operation> iterator() { return Iterators.concat(staticOperations.iterator(), regularOperations.iterator()); } public void addFunctionsTo(List<Function> functions) { regularOperations.forEach(p -> p.addFunctionsTo(functions)); staticOperations.forEach(p -> p.addFunctionsTo(functions)); } }