com.netflix.nicobar.cassandra

Class CassandraGatewayImpl

java.lang.Object

com.netflix.nicobar.cassandra.CassandraGatewayImpl

All Implemented Interfaces:

CassandraGateway

public class CassandraGatewayImpl
extends java.lang.Object
implements CassandraGateway

Concrete implementation of CassandraGateway, using Cassandra Hystrix commands. It is not ideal that this behavior is provided by nicobar-cassandra. Preferably, Astyanax itself should expose hystrix protected cassandra operations that we can directly use.

Constructor Summary

Constructors

Constructor and Description
CassandraGatewayImpl(com.netflix.astyanax.Keyspace keyspace, java.lang.String cf)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraGatewayImpl

public CassandraGatewayImpl(com.netflix.astyanax.Keyspace keyspace,
                    java.lang.String cf)

Method Detail

getKeyspace

public com.netflix.astyanax.Keyspace getKeyspace()

Description copied from interface: CassandraGateway

Return the keyspace that this gateway provides access to.

Specified by:

getKeyspace in interface CassandraGateway

Returns:

the Cassandra keyspace.

getColumnFamily

public java.lang.String getColumnFamily()

Description copied from interface: CassandraGateway

Return the column family that this gateway provides access to.

Specified by:

getColumnFamily in interface CassandraGateway

Returns:

a cassandra column family name.

upsert

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

Description copied from interface: CassandraGateway

Performs an insert/update for a row in Cassandra.

Specified by:

upsert in interface CassandraGateway

Parameters:

rowKey - the row key to use for insertions.

attributes - map of column names to column values.

upsert

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

Description copied from interface: CassandraGateway

Performs an insert/update for a row in Cassandra.

Specified by:

upsert in interface CassandraGateway

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.

getRow

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

Description copied from interface: CassandraGateway

Gets all columns for the specified row.

Specified by:

getRow in interface CassandraGateway

Parameters:

rowKey - a single row key.

Returns:

list of columns for the row, possibly null.

getRows

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

Description copied from interface: CassandraGateway

Gets all columns for all the listed row keys.

Specified by:

getRows in interface CassandraGateway

Parameters:

rowKeys - a list of row keys.

Returns:

list of rows, possibly null.

select

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

Description copied from interface: CassandraGateway

Performs a CQL query and returns result.

Specified by:

select in interface CassandraGateway

Parameters:

cql - the CQL query string.

Returns:

resulting row set, could be null.

selectAsync

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

Description copied from interface: CassandraGateway

Performs a CQL query asynchronously

Specified by:

selectAsync in interface CassandraGateway

Parameters:

cql - the CQL query string.

Returns:

Future containing result row set.

getColumns

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

Description copied from interface: CassandraGateway

Gets specific columns from a specific row

Specified by:

getColumns in interface CassandraGateway

Parameters:

rowKey - the specific row's key.

columns - the specific columns

Returns:

retrieved column list, possibly null.

deleteRow

public void deleteRow(java.lang.String rowKey)

Description copied from interface: CassandraGateway

Deletes a row in Cassandra.

Specified by:

deleteRow in interface CassandraGateway

Parameters:

rowKey - the key of the row to delete.

deleteColumn

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

Description copied from interface: CassandraGateway

Deletes a column from a row in Cassandra.

Specified by:

deleteColumn in interface CassandraGateway

Parameters:

rowKey - the key of the row containing the column.

column - the name of the column to delete.