com.netflix.nicobar.cassandra

Interface CassandraGateway

All Known Implementing Classes:

CassandraGatewayImpl

public interface CassandraGateway

Common cassandra CRUD operations.

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteColumn(java.lang.String rowKey, java.lang.String column) Deletes a column from a row in Cassandra.
void	deleteRow(java.lang.String rowKey) Deletes a row in Cassandra.
java.lang.String	getColumnFamily() Return the column family that this gateway provides access to.
com.netflix.astyanax.model.ColumnList<java.lang.String>	getColumns(java.lang.String rowKey, java.lang.String... columns) Gets specific columns from a specific row
com.netflix.astyanax.Keyspace	getKeyspace() Return the keyspace that this gateway provides access to.
com.netflix.astyanax.model.ColumnList<java.lang.String>	getRow(java.lang.String rowKey) Gets all columns for the specified row.
com.netflix.astyanax.model.Rows<java.lang.String,java.lang.String>	getRows(java.lang.String... rowKeys) Gets all columns for all the listed row keys.
com.netflix.astyanax.model.Rows<java.lang.String,java.lang.String>	select(java.lang.String cql) Performs a CQL query and returns result.
java.util.concurrent.Future<com.netflix.astyanax.model.Rows<java.lang.String,java.lang.String>>	selectAsync(java.lang.String cql) Performs a CQL query asynchronously
void	upsert(java.lang.String rowKey, java.util.Map<java.lang.String,java.lang.Object> attributes) Performs an insert/update for a row in Cassandra.
void	upsert(java.lang.String rowKey, java.util.Map<java.lang.String,java.lang.Object> attributes, int ttlSeconds) Performs an insert/update for a row in Cassandra.

Method Detail

getKeyspace

com.netflix.astyanax.Keyspace getKeyspace()

Return the keyspace that this gateway provides access to.

Returns:

the Cassandra keyspace.

getColumnFamily

java.lang.String getColumnFamily()

Return the column family that this gateway provides access to.

Returns:

a cassandra column family name.

upsert

void upsert(java.lang.String rowKey,
          java.util.Map<java.lang.String,java.lang.Object> attributes)

Performs an insert/update for a row in Cassandra.

Parameters:

rowKey - the row key to use for insertions.

attributes - map of column names to column values.

upsert

void upsert(java.lang.String rowKey,
          java.util.Map<java.lang.String,java.lang.Object> attributes,
          int ttlSeconds)

Performs an insert/update for a row in Cassandra.

Parameters:

rowKey - the row key to use for insertions

attributes - map of column names to column values.

ttlSeconds - how long should columns in this upsert live.

deleteRow

void deleteRow(java.lang.String rowKey)

Deletes a row in Cassandra.

Parameters:

rowKey - the key of the row to delete.

deleteColumn

void deleteColumn(java.lang.String rowKey,
                java.lang.String column)

Deletes a column from a row in Cassandra.

Parameters:

rowKey - the key of the row containing the column.

column - the name of the column to delete.

getColumns

com.netflix.astyanax.model.ColumnList<java.lang.String> getColumns(java.lang.String rowKey,
                                                                 java.lang.String... columns)

Gets specific columns from a specific row

Parameters:

rowKey - the specific row's key.

columns - the specific columns

Returns:

retrieved column list, possibly null.

getRow

com.netflix.astyanax.model.ColumnList<java.lang.String> getRow(java.lang.String rowKey)

Gets all columns for the specified row.

Parameters:

rowKey - a single row key.

Returns:

list of columns for the row, possibly null.

getRows

com.netflix.astyanax.model.Rows<java.lang.String,java.lang.String> getRows(java.lang.String... rowKeys)

Gets all columns for all the listed row keys.

Parameters:

rowKeys - a list of row keys.

Returns:

list of rows, possibly null.

select

com.netflix.astyanax.model.Rows<java.lang.String,java.lang.String> select(java.lang.String cql)

Performs a CQL query and returns result.

Parameters:

cql - the CQL query string.

Returns:

resulting row set, could be null.

selectAsync

java.util.concurrent.Future<com.netflix.astyanax.model.Rows<java.lang.String,java.lang.String>> selectAsync(java.lang.String cql)

Performs a CQL query asynchronously

Parameters:

cql - the CQL query string.

Returns:

Future containing result row set.