Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.scale7.cassandra.pelops
Class Selector

java.lang.Object
  extended by org.scale7.cassandra.pelops.Operand
      extended by org.scale7.cassandra.pelops.Selector

public class Selector
extends Operand

Facilitates the selective retrieval of column data from rows in a Cassandra keyspace.

Note:The methods that are marked as throwing NotFoundException are the only methods in Pelops that throw exceptions under non-failure conditions.

Author:
dominicwilliams

Nested Class Summary
static class Selector.OrderType
          Deprecated. 
 
Nested classes/interfaces inherited from class org.scale7.cassandra.pelops.Operand
Operand.IOperation<ReturnType>
 
Field Summary
 
Fields inherited from class org.scale7.cassandra.pelops.Operand
thrift
 
Constructor Summary
Selector(IThriftPool thrift)
          Create a batch mutation operation.
 
Method Summary
static boolean columnExists(List<org.apache.cassandra.thrift.Column> columns, Bytes colName)
          Determines if a column with a particular name exist in the list of columns.
static boolean columnExists(List<org.apache.cassandra.thrift.Column> columns, String colName)
          Determines if a column with a particular name exist in the list of columns.
 int getColumnCount(String columnFamily, Bytes rowKey, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of columns in a row.
 int getColumnCount(String columnFamily, Bytes rowKey, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of columns in a row.
 int getColumnCount(String columnFamily, String rowKey, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of columns in a row.
 int getColumnCount(String columnFamily, String rowKey, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of columns in a row.
 org.apache.cassandra.thrift.Column getColumnFromRow(String columnFamily, Bytes rowKey, Bytes colName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a column from a row.
 org.apache.cassandra.thrift.Column getColumnFromRow(String columnFamily, String rowKey, Bytes colName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a column from a row.
 org.apache.cassandra.thrift.Column getColumnFromRow(String columnFamily, String rowKey, String colName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a column from a row.
 List<org.apache.cassandra.thrift.Column> getColumnsFromRow(String columnFamily, Bytes rowKey, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a row.
 List<org.apache.cassandra.thrift.Column> getColumnsFromRow(String columnFamily, String rowKey, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a row.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getColumnsFromRows(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a range of rows.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getColumnsFromRows(String columnFamily, List<Bytes> rowKeys, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a set of rows.
 Map<String,List<org.apache.cassandra.thrift.Column>> getColumnsFromRowsUtf8Keys(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a range of rows.
 Map<String,List<org.apache.cassandra.thrift.Column>> getColumnsFromRowsUtf8Keys(String columnFamily, List<String> rowKeys, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a set of rows.
static String getColumnStringName(org.apache.cassandra.thrift.Column column)
          Get the name of a column as a UTF8 string
static String getColumnStringValue(org.apache.cassandra.thrift.Column column)
          Get the value of a column as a UTF8 string
static String getColumnStringValue(List<org.apache.cassandra.thrift.Column> columns, Bytes colName)
          Get the value of a column in a list of columns
static String getColumnStringValue(List<org.apache.cassandra.thrift.Column> columns, String colName)
          Get the value of a column in a list of columns
static long getColumnTimestamp(List<org.apache.cassandra.thrift.Column> columns, Bytes colName)
          Get the time stamp of a column in a list of columns.
static long getColumnTimestamp(List<org.apache.cassandra.thrift.Column> columns, String colName)
          Get the time stamp of a column in a list of columns.
static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns, Bytes colName)
          Get the value of a column in a list of columns
static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns, Bytes colName, Bytes defaultValue)
          Get the value of a column in a list of columns
static String getColumnValue(List<org.apache.cassandra.thrift.Column> columns, Bytes colName, String defaultValue)
          Get the value of a column in a list of columns
static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns, String colName)
          Get the value of a column in a list of columns
static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns, String colName, Bytes defaultValue)
          Get the value of a column in a list of columns
static String getColumnValue(List<org.apache.cassandra.thrift.Column> columns, String colName, String defaultValue)
          Get the value of a column in a list of columns
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getIndexedColumns(org.apache.cassandra.thrift.ColumnParent colParent, org.apache.cassandra.thrift.IndexClause indexClause, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a range of indexed rows using its secondary index.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getIndexedColumns(String colParent, org.apache.cassandra.thrift.IndexClause indexClause, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve columns from a range of indexed rows using its secondary index.
 List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily, Bytes rowKey, Bytes startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of columns composed from a segment of the sequence of columns in a row.
 List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily, Bytes rowKey, String startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of columns composed from a segment of the sequence of columns in a row.
 List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily, String rowKey, Bytes startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of columns composed from a segment of the sequence of columns in a row.
 List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily, String rowKey, String startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of columns composed from a segment of the sequence of columns in a row.
 List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily, Bytes rowKey, Bytes startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.
 List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily, Bytes rowKey, String startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.
 List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily, String rowKey, Bytes startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.
 List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily, String rowKey, String startBeyondName, boolean reversed, int count, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.
 int getSubColumnCount(String columnFamily, Bytes rowKey, Bytes superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, Bytes rowKey, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, Bytes rowKey, String superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, Bytes rowKey, String superColName, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, String rowKey, Bytes superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, String rowKey, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, String rowKey, String superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 int getSubColumnCount(String columnFamily, String rowKey, String superColName, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of sub-columns inside a super column in a row.
 org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily, Bytes rowKey, Bytes superColName, Bytes subColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a sub column from a super column in a row.
 org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily, String rowKey, Bytes superColName, Bytes subColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a sub column from a super column in a row.
 org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily, String rowKey, Bytes superColName, String subColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a sub column from a super column in a row.
 org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily, String rowKey, String superColName, Bytes subColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a sub column from a super column in a row.
 org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily, String rowKey, String superColName, String subColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a sub column from a super column in a row.
 List<org.apache.cassandra.thrift.Column> getSubColumnsFromRow(String columnFamily, Bytes rowKey, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a row.
 List<org.apache.cassandra.thrift.Column> getSubColumnsFromRow(String columnFamily, String rowKey, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a row.
 List<org.apache.cassandra.thrift.Column> getSubColumnsFromRow(String columnFamily, String rowKey, String superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a row.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a range of rows.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, String superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a range of rows.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily, List<Bytes> rowKeys, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a set of rows.
 Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily, List<Bytes> rowKeys, String superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a set of rows.
 Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a range of rows.
 Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, String superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a range of rows.
 Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily, List<String> rowKeys, Bytes superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a set of rows.
 Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily, List<String> rowKeys, String superColName, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve sub-columns from a super column in a set of rows.
static org.apache.cassandra.thrift.SuperColumn getSuperColumn(List<org.apache.cassandra.thrift.SuperColumn> superColumns, Bytes superColName)
          Get a super column by name from a list of super columns
static org.apache.cassandra.thrift.SuperColumn getSuperColumn(List<org.apache.cassandra.thrift.SuperColumn> superColumns, String superColName)
          Get a super column by name from a list of super columns
 int getSuperColumnCount(String columnFamily, Bytes rowKey, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of super columns in a row.
 int getSuperColumnCount(String columnFamily, Bytes rowKey, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of super columns in a row.
 int getSuperColumnCount(String columnFamily, String rowKey, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of super columns in a row.
 int getSuperColumnCount(String columnFamily, String rowKey, org.apache.cassandra.thrift.SlicePredicate predicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Get the count of super columns in a row.
 org.apache.cassandra.thrift.SuperColumn getSuperColumnFromRow(String columnFamily, Bytes rowKey, Bytes superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a super column from a row.
 org.apache.cassandra.thrift.SuperColumn getSuperColumnFromRow(String columnFamily, String rowKey, Bytes superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a super column from a row.
 org.apache.cassandra.thrift.SuperColumn getSuperColumnFromRow(String columnFamily, String rowKey, String superColName, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve a super column from a row.
 List<org.apache.cassandra.thrift.SuperColumn> getSuperColumnsFromRow(String columnFamily, Bytes rowKey, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve super columns from a row.
 List<org.apache.cassandra.thrift.SuperColumn> getSuperColumnsFromRow(String columnFamily, String rowKey, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve super columns from a row.
 Map<Bytes,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRows(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve super columns from a range of rows.
 Map<Bytes,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRows(String columnFamily, List<Bytes> rowKeys, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve super columns from a set of rows.
 Map<String,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRowsUtf8Keys(String columnFamily, org.apache.cassandra.thrift.KeyRange keyRange, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve super columns from a range of rows.
 Map<String,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRowsUtf8Keys(String columnFamily, List<String> rowKeys, org.apache.cassandra.thrift.SlicePredicate colPredicate, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Retrieve super columns from a set of rows.
 Iterator<org.apache.cassandra.thrift.Column> iterateColumnsFromRow(String columnFamily, Bytes rowKey, Bytes startBeyondName, boolean reversed, int batchSize, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Returns an iterator that can be used to iterate over super columns.
 Iterator<org.apache.cassandra.thrift.Column> iterateColumnsFromRow(String columnFamily, String rowKey, String startBeyondName, boolean reversed, int batchSize, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Returns an iterator that can be used to iterate over super columns.
 Iterator<org.apache.cassandra.thrift.SuperColumn> iterateSuperColumnsFromRow(String columnFamily, Bytes rowKey, Bytes startBeyondName, boolean reversed, int batchSize, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Returns an iterator that can be used to iterate over super columns.
 Iterator<org.apache.cassandra.thrift.SuperColumn> iterateSuperColumnsFromRow(String columnFamily, String rowKey, String startBeyondName, boolean reversed, int batchSize, org.apache.cassandra.thrift.ConsistencyLevel cLevel)
          Returns an iterator that can be used to iterate over super columns.
static org.apache.cassandra.thrift.ColumnParent newColumnParent(String columnFamily)
           
static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(Bytes... colNames)
          Create a new SlicePredicate instance.
static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(Bytes startName, Bytes finishName, boolean reversed, int maxColCount)
          Create a new SlicePredicate instance.
static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(String... colNames)
          Create a new SlicePredicate instance.
static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(String startName, String finishName, boolean reversed, int maxColCount)
          Create a new SlicePredicate instance.
static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicateAll(boolean reversed, int maxColCount)
          Create a new SlicePredicate instance that selects "all" columns
static org.apache.cassandra.thrift.IndexClause newIndexClause(Bytes startName, int count, org.apache.cassandra.thrift.IndexExpression... expressions)
          Create a new IndexClause instance.
static org.apache.cassandra.thrift.IndexClause newIndexClause(String startName, int count, org.apache.cassandra.thrift.IndexExpression... expressions)
          Create a new IndexClause instance.
static org.apache.cassandra.thrift.IndexExpression newIndexExpression(Bytes colName, org.apache.cassandra.thrift.IndexOperator op, Bytes value)
          Create a new IndexExpression instance.
static org.apache.cassandra.thrift.IndexExpression newIndexExpression(String colName, org.apache.cassandra.thrift.IndexOperator op, Bytes value)
          Create a new IndexExpression instance.
static org.apache.cassandra.thrift.KeyRange newKeyRange(Bytes startKey, Bytes finishKey, int maxKeyCount)
          Create a new KeyRange instance.
static org.apache.cassandra.thrift.KeyRange newKeyRange(String startKey, String finishKey, int maxKeyCount)
          Create a new KeyRange instance.
static org.apache.cassandra.thrift.KeyRange newKeyRingRange(String startFollowingKey, String finishKey, int maxKeyCount)
          Create a new KeyRange instance.
static boolean superColumnExists(List<org.apache.cassandra.thrift.SuperColumn> superColumns, Bytes superColName)
          Determines if a super column with a particular name exist in the list of super columns.
static boolean superColumnExists(List<org.apache.cassandra.thrift.SuperColumn> superColumns, String superColName)
          Determines if a super column with a particular name exist in the list of super columns.
 
Methods inherited from class org.scale7.cassandra.pelops.Operand
tryOperation
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Selector

public Selector(IThriftPool thrift)
Create a batch mutation operation.

Method Detail

getColumnCount

public int getColumnCount(String columnFamily,
                          Bytes rowKey,
                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                   throws PelopsException
Get the count of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the columns
Throws:
PelopsException - if an error occurs

getColumnCount

public int getColumnCount(String columnFamily,
                          Bytes rowKey,
                          org.apache.cassandra.thrift.SlicePredicate predicate,
                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                   throws PelopsException
Get the count of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
predicate - A predicate selecting the columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the columns
Throws:
PelopsException - if an error occurs

getColumnCount

public int getColumnCount(String columnFamily,
                          String rowKey,
                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                   throws PelopsException
Get the count of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the columns
Throws:
PelopsException - if an error occurs

getColumnCount

public int getColumnCount(String columnFamily,
                          String rowKey,
                          org.apache.cassandra.thrift.SlicePredicate predicate,
                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                   throws PelopsException
Get the count of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
predicate - A predicate selecting the columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             String rowKey,
                             Bytes superColName,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             String rowKey,
                             Bytes superColName,
                             org.apache.cassandra.thrift.SlicePredicate predicate,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
predicate - A predicate selecting the sub columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             Bytes rowKey,
                             Bytes superColName,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             Bytes rowKey,
                             Bytes superColName,
                             org.apache.cassandra.thrift.SlicePredicate predicate,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
predicate - A predicate selecting the sub columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             String rowKey,
                             String superColName,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             String rowKey,
                             String superColName,
                             org.apache.cassandra.thrift.SlicePredicate predicate,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
predicate - A predicate selecting the sub columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             Bytes rowKey,
                             String superColName,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnCount

public int getSubColumnCount(String columnFamily,
                             Bytes rowKey,
                             String superColName,
                             org.apache.cassandra.thrift.SlicePredicate predicate,
                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                      throws PelopsException
Get the count of sub-columns inside a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column
predicate - A predicate selecting the sub columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the sub-columns
Throws:
PelopsException - if an error occurs

getSuperColumnCount

public int getSuperColumnCount(String columnFamily,
                               Bytes rowKey,
                               org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                        throws PelopsException
Get the count of super columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the super columns
Throws:
PelopsException - if an error occurs

getSuperColumnCount

public int getSuperColumnCount(String columnFamily,
                               Bytes rowKey,
                               org.apache.cassandra.thrift.SlicePredicate predicate,
                               org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                        throws PelopsException
Get the count of super columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
predicate - A predicate selecting the super columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the super columns
Throws:
PelopsException - if an error occurs

getSuperColumnCount

public int getSuperColumnCount(String columnFamily,
                               String rowKey,
                               org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                        throws PelopsException
Get the count of super columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the super columns
Throws:
PelopsException - if an error occurs

getSuperColumnCount

public int getSuperColumnCount(String columnFamily,
                               String rowKey,
                               org.apache.cassandra.thrift.SlicePredicate predicate,
                               org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                        throws PelopsException
Get the count of super columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
predicate - A predicate selecting the super columns to be counted
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The count of the super columns
Throws:
PelopsException - if an error occurs

getColumnFromRow

public org.apache.cassandra.thrift.Column getColumnFromRow(String columnFamily,
                                                           String rowKey,
                                                           String colName,
                                                           org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                    throws NotFoundException,
                                                           PelopsException
Retrieve a column from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
colName - The name of the column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getColumnFromRow

public org.apache.cassandra.thrift.Column getColumnFromRow(String columnFamily,
                                                           String rowKey,
                                                           Bytes colName,
                                                           org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                    throws NotFoundException,
                                                           PelopsException
Retrieve a column from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
colName - The name of the column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getColumnFromRow

public org.apache.cassandra.thrift.Column getColumnFromRow(String columnFamily,
                                                           Bytes rowKey,
                                                           Bytes colName,
                                                           org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                    throws NotFoundException,
                                                           PelopsException
Retrieve a column from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
colName - The name of the column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSuperColumnFromRow

public org.apache.cassandra.thrift.SuperColumn getSuperColumnFromRow(String columnFamily,
                                                                     String rowKey,
                                                                     String superColName,
                                                                     org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                              throws NotFoundException,
                                                                     PelopsException
Retrieve a super column from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested SuperColumn
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSuperColumnFromRow

public org.apache.cassandra.thrift.SuperColumn getSuperColumnFromRow(String columnFamily,
                                                                     String rowKey,
                                                                     Bytes superColName,
                                                                     org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                              throws NotFoundException,
                                                                     PelopsException
Retrieve a super column from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested SuperColumn
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSuperColumnFromRow

public org.apache.cassandra.thrift.SuperColumn getSuperColumnFromRow(String columnFamily,
                                                                     Bytes rowKey,
                                                                     Bytes superColName,
                                                                     org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                              throws NotFoundException,
                                                                     PelopsException
Retrieve a super column from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested SuperColumn
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSubColumnFromRow

public org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily,
                                                              String rowKey,
                                                              Bytes superColName,
                                                              String subColName,
                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                       throws NotFoundException,
                                                              PelopsException
Retrieve a sub column from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column containing the sub column
subColName - The name of the sub column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSubColumnFromRow

public org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily,
                                                              String rowKey,
                                                              String superColName,
                                                              String subColName,
                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                       throws NotFoundException,
                                                              PelopsException
Retrieve a sub column from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column containing the sub column
subColName - The name of the sub column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSubColumnFromRow

public org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily,
                                                              String rowKey,
                                                              String superColName,
                                                              Bytes subColName,
                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                       throws NotFoundException,
                                                              PelopsException
Retrieve a sub column from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column containing the sub column
subColName - The name of the sub column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSubColumnFromRow

public org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily,
                                                              String rowKey,
                                                              Bytes superColName,
                                                              Bytes subColName,
                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                       throws NotFoundException,
                                                              PelopsException
Retrieve a sub column from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column containing the sub column
subColName - The name of the sub column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getSubColumnFromRow

public org.apache.cassandra.thrift.Column getSubColumnFromRow(String columnFamily,
                                                              Bytes rowKey,
                                                              Bytes superColName,
                                                              Bytes subColName,
                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                       throws NotFoundException,
                                                              PelopsException
Retrieve a sub column from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
superColName - The name of the super column containing the sub column
subColName - The name of the sub column to retrieve
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
The requested Column
Throws:
NotFoundException - If no value is present
PelopsException - if an error occurs

getColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getColumnsFromRow(String columnFamily,
                                                                  String rowKey,
                                                                  org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                  org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                           throws PelopsException
Retrieve columns from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getColumnsFromRow(String columnFamily,
                                                                  Bytes rowKey,
                                                                  org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                  org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                           throws PelopsException
Retrieve columns from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getSubColumnsFromRow(String columnFamily,
                                                                     Bytes rowKey,
                                                                     Bytes superColName,
                                                                     org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                     org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                              throws PelopsException
Retrieve sub-columns from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the super column
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getSubColumnsFromRow(String columnFamily,
                                                                     String rowKey,
                                                                     Bytes superColName,
                                                                     org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                     org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                              throws PelopsException
Retrieve sub-columns from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the super column
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getSubColumnsFromRow(String columnFamily,
                                                                     String rowKey,
                                                                     String superColName,
                                                                     org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                     org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                              throws PelopsException
Retrieve sub-columns from a super column in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the super column
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getSuperColumnsFromRow

public List<org.apache.cassandra.thrift.SuperColumn> getSuperColumnsFromRow(String columnFamily,
                                                                            String rowKey,
                                                                            org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                            org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                     throws PelopsException
Retrieve super columns from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the super columns
colPredicate - The super column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getSuperColumnsFromRow

public List<org.apache.cassandra.thrift.SuperColumn> getSuperColumnsFromRow(String columnFamily,
                                                                            Bytes rowKey,
                                                                            org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                            org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                     throws PelopsException
Retrieve super columns from a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the super columns
colPredicate - The super column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A list of matching columns
Throws:
PelopsException - if an error occurs

getPageOfColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily,
                                                                        String rowKey,
                                                                        Bytes startBeyondName,
                                                                        boolean reversed,
                                                                        int count,
                                                                        org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                 throws PelopsException
Retrieve a page of columns composed from a segment of the sequence of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the columns
startBeyondName - The sequence of columns must begin with the smallest column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending column name order
count - The maximum number of columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of columns
Throws:
PelopsException - if an error occurs

getPageOfColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily,
                                                                        String rowKey,
                                                                        String startBeyondName,
                                                                        boolean reversed,
                                                                        int count,
                                                                        org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                 throws PelopsException
Retrieve a page of columns composed from a segment of the sequence of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the columns
startBeyondName - The sequence of columns must begin with the smallest column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending column name order
count - The maximum number of columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of columns
Throws:
PelopsException - if an error occurs

getPageOfColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily,
                                                                        Bytes rowKey,
                                                                        String startBeyondName,
                                                                        boolean reversed,
                                                                        int count,
                                                                        org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                 throws PelopsException
Retrieve a page of columns composed from a segment of the sequence of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the columns
startBeyondName - The sequence of columns must begin with the smallest column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending column name order
count - The maximum number of columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of columns
Throws:
PelopsException - if an error occurs

getPageOfColumnsFromRow

public List<org.apache.cassandra.thrift.Column> getPageOfColumnsFromRow(String columnFamily,
                                                                        Bytes rowKey,
                                                                        Bytes startBeyondName,
                                                                        boolean reversed,
                                                                        int count,
                                                                        org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                 throws PelopsException
Retrieve a page of columns composed from a segment of the sequence of columns in a row.

Parameters:
columnFamily - The column family containing the row
rowKey - The key of the row containing the columns
startBeyondName - The sequence of columns must begin with the smallest column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending column name order
count - The maximum number of columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of columns
Throws:
PelopsException - if an error occurs

iterateColumnsFromRow

public Iterator<org.apache.cassandra.thrift.Column> iterateColumnsFromRow(String columnFamily,
                                                                          Bytes rowKey,
                                                                          Bytes startBeyondName,
                                                                          boolean reversed,
                                                                          int batchSize,
                                                                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
Returns an iterator that can be used to iterate over super columns. The returned iterator delegates to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) to fetch batches of super columns (based on the batchSize parameter).

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
batchSize - The maximum number of super columns that can be retrieved per invocation to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) and dictates the number of super columns to be held in memory at any one time
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

iterateColumnsFromRow

public Iterator<org.apache.cassandra.thrift.Column> iterateColumnsFromRow(String columnFamily,
                                                                          String rowKey,
                                                                          String startBeyondName,
                                                                          boolean reversed,
                                                                          int batchSize,
                                                                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
Returns an iterator that can be used to iterate over super columns. The returned iterator delegates to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) to fetch batches of super columns (based on the batchSize parameter).

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
batchSize - The maximum number of super columns that can be retrieved per invocation to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) and dictates the number of super columns to be held in memory at any one time
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

getPageOfSuperColumnsFromRow

public List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily,
                                                                                  String rowKey,
                                                                                  Bytes startBeyondName,
                                                                                  boolean reversed,
                                                                                  int count,
                                                                                  org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                           throws PelopsException
Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
count - The maximum number of super columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

getPageOfSuperColumnsFromRow

public List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily,
                                                                                  String rowKey,
                                                                                  String startBeyondName,
                                                                                  boolean reversed,
                                                                                  int count,
                                                                                  org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                           throws PelopsException
Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
count - The maximum number of super columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

getPageOfSuperColumnsFromRow

public List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily,
                                                                                  Bytes rowKey,
                                                                                  String startBeyondName,
                                                                                  boolean reversed,
                                                                                  int count,
                                                                                  org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                           throws PelopsException
Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
count - The maximum number of super columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

getPageOfSuperColumnsFromRow

public List<org.apache.cassandra.thrift.SuperColumn> getPageOfSuperColumnsFromRow(String columnFamily,
                                                                                  Bytes rowKey,
                                                                                  Bytes startBeyondName,
                                                                                  boolean reversed,
                                                                                  int count,
                                                                                  org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                           throws PelopsException
Retrieve a page of super columns composed from a segment of the sequence of super columns in a row.

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
count - The maximum number of super columns that can be retrieved by the scan
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

iterateSuperColumnsFromRow

public Iterator<org.apache.cassandra.thrift.SuperColumn> iterateSuperColumnsFromRow(String columnFamily,
                                                                                    Bytes rowKey,
                                                                                    Bytes startBeyondName,
                                                                                    boolean reversed,
                                                                                    int batchSize,
                                                                                    org.apache.cassandra.thrift.ConsistencyLevel cLevel)
Returns an iterator that can be used to iterate over super columns. The returned iterator delegates to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) to fetch batches of super columns (based on the batchSize parameter).

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
batchSize - The maximum number of super columns that can be retrieved per invocation to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) and dictates the number of super columns to be held in memory at any one time
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

iterateSuperColumnsFromRow

public Iterator<org.apache.cassandra.thrift.SuperColumn> iterateSuperColumnsFromRow(String columnFamily,
                                                                                    String rowKey,
                                                                                    String startBeyondName,
                                                                                    boolean reversed,
                                                                                    int batchSize,
                                                                                    org.apache.cassandra.thrift.ConsistencyLevel cLevel)
Returns an iterator that can be used to iterate over super columns. The returned iterator delegates to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) to fetch batches of super columns (based on the batchSize parameter).

Parameters:
columnFamily - The name of the column family containing the super columns
rowKey - The key of the row
startBeyondName - The sequence of super columns must begin with the smallest super column name greater than this value. Pass null to start at the beginning of the sequence.
reversed - Whether the scan should proceed in descending super column name order
batchSize - The maximum number of super columns that can be retrieved per invocation to getPageOfSuperColumnsFromRow(String, String, Bytes, boolean, int, org.apache.cassandra.thrift.ConsistencyLevel) and dictates the number of super columns to be held in memory at any one time
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A page of super columns
Throws:
PelopsException - if an error occurs

getColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getColumnsFromRows(String columnFamily,
                                                                              List<Bytes> rowKeys,
                                                                              org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                       throws PelopsException
Retrieve columns from a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the columns
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of columns
Throws:
PelopsException - if an error occurs

getColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.Column>> getColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                       List<String> rowKeys,
                                                                                       org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                       org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                throws PelopsException
Retrieve columns from a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the columns
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily,
                                                                                 List<Bytes> rowKeys,
                                                                                 String superColName,
                                                                                 org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                 org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                          throws PelopsException
Retrieve sub-columns from a super column in a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the super columns
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                          List<String> rowKeys,
                                                                                          String superColName,
                                                                                          org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                   throws PelopsException
Retrieve sub-columns from a super column in a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the super columns
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily,
                                                                                 List<Bytes> rowKeys,
                                                                                 Bytes superColName,
                                                                                 org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                 org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                          throws PelopsException
Retrieve sub-columns from a super column in a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the super columns
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                          List<String> rowKeys,
                                                                                          Bytes superColName,
                                                                                          org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                   throws PelopsException
Retrieve sub-columns from a super column in a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the super columns
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSuperColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRows(String columnFamily,
                                                                                        List<Bytes> rowKeys,
                                                                                        org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                        org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                 throws PelopsException
Retrieve super columns from a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the super columns
colPredicate - The super column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of super columns
Throws:
PelopsException - if an error occurs

getSuperColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                                 List<String> rowKeys,
                                                                                                 org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                                 org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                          throws PelopsException
Retrieve super columns from a set of rows.

Parameters:
columnFamily - The column family containing the rows
rowKeys - The keys of the rows containing the super columns
colPredicate - The super column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of super columns
Throws:
PelopsException - if an error occurs

getColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getColumnsFromRows(String columnFamily,
                                                                              org.apache.cassandra.thrift.KeyRange keyRange,
                                                                              org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                              org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                       throws PelopsException
Retrieve columns from a range of rows. The method returns a map from the keys of rows in the specified range to lists of columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of columns
Throws:
PelopsException - if an error occurs

getColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.Column>> getColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                       org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                       org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                       org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                throws PelopsException
Retrieve columns from a range of rows. The method returns a map from the keys of rows in the specified range to lists of columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily,
                                                                                 org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                 Bytes superColName,
                                                                                 org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                 org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                          throws PelopsException
Retrieve sub-columns from a super column in a range of rows. The method returns a map from the keys of rows in the specified range to lists of sub-columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                          org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                          Bytes superColName,
                                                                                          org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                   throws PelopsException
Retrieve sub-columns from a super column in a range of rows. The method returns a map from the keys of rows in the specified range to lists of sub-columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRows(String columnFamily,
                                                                                 org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                 String superColName,
                                                                                 org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                 org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                          throws PelopsException
Retrieve sub-columns from a super column in a range of rows. The method returns a map from the keys of rows in the specified range to lists of sub-columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSubColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.Column>> getSubColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                          org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                          String superColName,
                                                                                          org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                          org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                   throws PelopsException
Retrieve sub-columns from a super column in a range of rows. The method returns a map from the keys of rows in the specified range to lists of sub-columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
superColName - The name of the super column
colPredicate - The sub-column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of sub-columns
Throws:
PelopsException - if an error occurs

getSuperColumnsFromRows

public Map<Bytes,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRows(String columnFamily,
                                                                                        org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                        org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                        org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                 throws PelopsException
Retrieve super columns from a range of rows. The method returns a map from the keys of rows in the specified range to lists of super columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
colPredicate - The super column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of super columns
Throws:
PelopsException - if an error occurs

getSuperColumnsFromRowsUtf8Keys

public Map<String,List<org.apache.cassandra.thrift.SuperColumn>> getSuperColumnsFromRowsUtf8Keys(String columnFamily,
                                                                                                 org.apache.cassandra.thrift.KeyRange keyRange,
                                                                                                 org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                                                 org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                                          throws PelopsException
Retrieve super columns from a range of rows. The method returns a map from the keys of rows in the specified range to lists of super columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
columnFamily - The column family containing the rows
keyRange - A key range selecting the rows
colPredicate - The super column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of super columns
Throws:
PelopsException - if an error occurs

getIndexedColumns

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getIndexedColumns(String colParent,
                                                                             org.apache.cassandra.thrift.IndexClause indexClause,
                                                                             org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                      throws PelopsException
Retrieve columns from a range of indexed rows using its secondary index. The method returns a map from the keys of indexed rows in the specified range to lists of columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
colParent - The column parent containing the rows
indexClause - A index clause
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of columns
Throws:
PelopsException - if an error occurs

getIndexedColumns

public Map<Bytes,List<org.apache.cassandra.thrift.Column>> getIndexedColumns(org.apache.cassandra.thrift.ColumnParent colParent,
                                                                             org.apache.cassandra.thrift.IndexClause indexClause,
                                                                             org.apache.cassandra.thrift.SlicePredicate colPredicate,
                                                                             org.apache.cassandra.thrift.ConsistencyLevel cLevel)
                                                                      throws PelopsException
Retrieve columns from a range of indexed rows using its secondary index. The method returns a map from the keys of indexed rows in the specified range to lists of columns from the rows. The map returned is a LinkedHashMap and its key iterator proceeds in the order that the key data was returned by Cassandra. If the cluster uses the RandomPartitioner, this order appears random.

Parameters:
colParent - The column parent
indexClause - A index key range selecting the rows
colPredicate - The column selector predicate
cLevel - The Cassandra consistency level with which to perform the operation
Returns:
A map from row keys to the matching lists of columns
Throws:
PelopsException - if an error occurs

newIndexExpression

public static org.apache.cassandra.thrift.IndexExpression newIndexExpression(Bytes colName,
                                                                             org.apache.cassandra.thrift.IndexOperator op,
                                                                             Bytes value)
Create a new IndexExpression instance.

Parameters:
colName - The name of the column
op - The index expression operator (for now only EQ works)
value - Lookup value
Returns:
The new IndexExpression

newIndexExpression

public static org.apache.cassandra.thrift.IndexExpression newIndexExpression(String colName,
                                                                             org.apache.cassandra.thrift.IndexOperator op,
                                                                             Bytes value)
Create a new IndexExpression instance.

Parameters:
colName - The name of the column
op - The index expression operator (for now only EQ works)
value - Lookup value
Returns:
The new IndexExpression

newIndexClause

public static org.apache.cassandra.thrift.IndexClause newIndexClause(String startName,
                                                                     int count,
                                                                     org.apache.cassandra.thrift.IndexExpression... expressions)
Create a new IndexClause instance.

Parameters:
startName - The inclusive column start name of the index range to select in the slice
count - The maximum number of rows to return
expressions - Index value lookup expressions
Returns:
The new IndexClause

newIndexClause

public static org.apache.cassandra.thrift.IndexClause newIndexClause(Bytes startName,
                                                                     int count,
                                                                     org.apache.cassandra.thrift.IndexExpression... expressions)
Create a new IndexClause instance.

Parameters:
startName - The inclusive column start name of the index range to select in the slice
count - The maximum number of rows to return
expressions - Index value lookup expressions
Returns:
The new IndexClause

newColumnsPredicateAll

public static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicateAll(boolean reversed,
                                                                                int maxColCount)
Create a new SlicePredicate instance that selects "all" columns

Parameters:
reversed - Whether the results should be returned in reverse order
maxColCount - The maximum number of columns to return
Returns:
The new SlicePredicate

newColumnsPredicate

public static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(Bytes startName,
                                                                             Bytes finishName,
                                                                             boolean reversed,
                                                                             int maxColCount)
Create a new SlicePredicate instance.

Parameters:
startName - The inclusive column start name of the range to select in the slice
finishName - The inclusive column end name of the range to select in the slice
reversed - Whether the results should be returned in reverse order
maxColCount - The maximum number of columns to return
Returns:
The new SlicePredicate

newColumnsPredicate

public static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(String startName,
                                                                             String finishName,
                                                                             boolean reversed,
                                                                             int maxColCount)
Create a new SlicePredicate instance.

Parameters:
startName - The inclusive column start name of the range to select in the slice
finishName - The inclusive column end name of the range to select in the slice
reversed - Whether the results should be returned in reverse order
maxColCount - The maximum number of columns to return
Returns:
The new SlicePredicate

newColumnsPredicate

public static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(String... colNames)
Create a new SlicePredicate instance.

Parameters:
colNames - The specific columns names to select in the slice
Returns:
The new SlicePredicate

newColumnsPredicate

public static org.apache.cassandra.thrift.SlicePredicate newColumnsPredicate(Bytes... colNames)
Create a new SlicePredicate instance.

Parameters:
colNames - The specific columns names to select in the slice
Returns:
The new SlicePredicate

newKeyRange

public static org.apache.cassandra.thrift.KeyRange newKeyRange(String startKey,
                                                               String finishKey,
                                                               int maxKeyCount)
Create a new KeyRange instance.

Parameters:
startKey - The inclusive start key of the range
finishKey - The inclusive finish key of the range
maxKeyCount - The maximum number of keys to be scanned
Returns:
The new KeyRange instance

newKeyRange

public static org.apache.cassandra.thrift.KeyRange newKeyRange(Bytes startKey,
                                                               Bytes finishKey,
                                                               int maxKeyCount)
Create a new KeyRange instance.

Parameters:
startKey - The inclusive start key of the range
finishKey - The inclusive finish key of the range
maxKeyCount - The maximum number of keys to be scanned
Returns:
The new KeyRange instance

newKeyRingRange

public static org.apache.cassandra.thrift.KeyRange newKeyRingRange(String startFollowingKey,
                                                                   String finishKey,
                                                                   int maxKeyCount)
Create a new KeyRange instance.

Parameters:
startFollowingKey - The exclusive start key of the ring range
finishKey - The inclusive finish key of the range (can be less than startFollowing)
maxKeyCount - The maximum number of keys to be scanned
Returns:
The new KeyRange instance

superColumnExists

public static boolean superColumnExists(List<org.apache.cassandra.thrift.SuperColumn> superColumns,
                                        String superColName)
Determines if a super column with a particular name exist in the list of super columns.

Parameters:
superColumns - The list of super columns
superColName - The name of the super column
Returns:
Whether the super column is present

superColumnExists

public static boolean superColumnExists(List<org.apache.cassandra.thrift.SuperColumn> superColumns,
                                        Bytes superColName)
Determines if a super column with a particular name exist in the list of super columns.

Parameters:
superColumns - The list of super columns
superColName - The name of the super column
Returns:
Whether the super column is present

getSuperColumn

public static org.apache.cassandra.thrift.SuperColumn getSuperColumn(List<org.apache.cassandra.thrift.SuperColumn> superColumns,
                                                                     Bytes superColName)
                                                              throws ArrayIndexOutOfBoundsException
Get a super column by name from a list of super columns

Parameters:
superColumns - The list of super columns
superColName - The name of the super column
Returns:
The super column
Throws:
ArrayIndexOutOfBoundsException - Thrown if the list does not contain a super column with the specified name

getSuperColumn

public static org.apache.cassandra.thrift.SuperColumn getSuperColumn(List<org.apache.cassandra.thrift.SuperColumn> superColumns,
                                                                     String superColName)
                                                              throws ArrayIndexOutOfBoundsException
Get a super column by name from a list of super columns

Parameters:
superColumns - The list of super columns
superColName - The name of the super column
Returns:
The super column
Throws:
ArrayIndexOutOfBoundsException - Thrown if the list does not contain a super column with the specified name

getColumnStringName

public static String getColumnStringName(org.apache.cassandra.thrift.Column column)
Get the name of a column as a UTF8 string

Parameters:
column - The column
Returns:
The byte[] name as a UTF8 string

getColumnStringValue

public static String getColumnStringValue(org.apache.cassandra.thrift.Column column)
Get the value of a column as a UTF8 string

Parameters:
column - The column containing the value
Returns:
The byte[] value as a UTF8 string

getColumnValue

public static String getColumnValue(List<org.apache.cassandra.thrift.Column> columns,
                                    String colName,
                                    String defaultValue)
                             throws UnsupportedEncodingException
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
defaultValue - A default value to return if a column with the specified name is not present in the list
Returns:
The column value
Throws:
UnsupportedEncodingException - Thrown if the column value was not a string

getColumnValue

public static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns,
                                   String colName,
                                   Bytes defaultValue)
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
defaultValue - A default value to return if a column with the specified name is not present in the list
Returns:
The column value

getColumnValue

public static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns,
                                   Bytes colName,
                                   Bytes defaultValue)
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
defaultValue - A default value to return if a column with the specified name is not present in the list
Returns:
The column value

getColumnValue

public static String getColumnValue(List<org.apache.cassandra.thrift.Column> columns,
                                    Bytes colName,
                                    String defaultValue)
                             throws UnsupportedEncodingException
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
defaultValue - A default value to return if a column with the specified name is not present in the list
Returns:
The column value
Throws:
UnsupportedEncodingException - Thrown if the column value was not a string

columnExists

public static boolean columnExists(List<org.apache.cassandra.thrift.Column> columns,
                                   Bytes colName)
Determines if a column with a particular name exist in the list of columns.

Parameters:
columns - The list of columns
colName - The name of the column
Returns:
Whether the column is present

columnExists

public static boolean columnExists(List<org.apache.cassandra.thrift.Column> columns,
                                   String colName)
Determines if a column with a particular name exist in the list of columns.

Parameters:
columns - The list of columns
colName - The name of the column
Returns:
Whether the column is present

getColumnValue

public static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns,
                                   Bytes colName)
                            throws ArrayIndexOutOfBoundsException
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
Returns:
The column value
Throws:
ArrayIndexOutOfBoundsException - Thrown if the specified column was not found

getColumnValue

public static Bytes getColumnValue(List<org.apache.cassandra.thrift.Column> columns,
                                   String colName)
                            throws ArrayIndexOutOfBoundsException
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
Returns:
The column value
Throws:
ArrayIndexOutOfBoundsException - Thrown if the specified column was not found

getColumnStringValue

public static String getColumnStringValue(List<org.apache.cassandra.thrift.Column> columns,
                                          String colName)
                                   throws ArrayIndexOutOfBoundsException,
                                          UnsupportedEncodingException
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
Returns:
The column value as a String
Throws:
ArrayIndexOutOfBoundsException - Thrown if the specified column was not found
UnsupportedEncodingException - Thrown if the column value did not contain a valid UTF-8 string

getColumnStringValue

public static String getColumnStringValue(List<org.apache.cassandra.thrift.Column> columns,
                                          Bytes colName)
                                   throws ArrayIndexOutOfBoundsException,
                                          UnsupportedEncodingException
Get the value of a column in a list of columns

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the value
Returns:
The column value as a String
Throws:
ArrayIndexOutOfBoundsException - Thrown if the specified column was not found
UnsupportedEncodingException - Thrown if the column value did not contain a valid UTF-8 string

getColumnTimestamp

public static long getColumnTimestamp(List<org.apache.cassandra.thrift.Column> columns,
                                      Bytes colName)
                               throws ArrayIndexOutOfBoundsException
Get the time stamp of a column in a list of columns.

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the timestamp
Returns:
The time stamp (the Mutator object uses time stamps as microseconds)
Throws:
UnsupportedEncodingException - Thrown if the column value did not contain a valid UTF-8 string
ArrayIndexOutOfBoundsException

getColumnTimestamp

public static long getColumnTimestamp(List<org.apache.cassandra.thrift.Column> columns,
                                      String colName)
                               throws ArrayIndexOutOfBoundsException
Get the time stamp of a column in a list of columns.

Parameters:
columns - The list of columns
colName - The name of the column from which to retrieve the timestamp
Returns:
The time stamp (the Mutator object uses time stamps as microseconds)
Throws:
UnsupportedEncodingException - Thrown if the column value did not contain a valid UTF-8 string
ArrayIndexOutOfBoundsException

newColumnParent

public static org.apache.cassandra.thrift.ColumnParent newColumnParent(String columnFamily)
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2011. All Rights Reserved.