com.netflix.nicobar.cassandra.internal

Class HystrixCassandraGetRowsByQuery<RowKeyType>

java.lang.Object

com.netflix.hystrix.HystrixCommand<K>

com.netflix.nicobar.cassandra.internal.AbstractCassandraHystrixCommand<com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>>

com.netflix.nicobar.cassandra.internal.HystrixCassandraGetRowsByQuery<RowKeyType>

Type Parameters:

RowKeyType - the type of the row key, String, Integer etc.

All Implemented Interfaces:

com.netflix.hystrix.HystrixExecutable<com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>>

public class HystrixCassandraGetRowsByQuery<RowKeyType>
extends AbstractCassandraHystrixCommand<com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>>

Hystrix command to get rows from Cassandra that match a particular CQL query. See http://crlog.info/2011/06/13/cassandra-query-language-cql-v1-0-0-updated/

Nested Class Summary

Nested classes/interfaces inherited from class com.netflix.hystrix.HystrixCommand

com.netflix.hystrix.HystrixCommand.Setter, com.netflix.hystrix.HystrixCommand.UnitTest

Constructor Summary

Constructors

Constructor and Description
HystrixCassandraGetRowsByQuery(com.netflix.astyanax.Keyspace keyspace, com.netflix.astyanax.model.ColumnFamily<RowKeyType,java.lang.String> columnFamily, java.lang.String cql) Get rows specified by their row keys.
HystrixCassandraGetRowsByQuery(com.netflix.astyanax.Keyspace keyspace, java.lang.String columnFamilyName, java.lang.Class<?> columnFamilyKeyType, java.lang.String cql) Get rows specified by their row keys.

Method Summary

Methods

Modifier and Type	Method and Description
protected com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>	run()

Methods inherited from class com.netflix.nicobar.cassandra.internal.AbstractCassandraHystrixCommand

getColumnFamilyViaColumnName, getColumnFamilyViaColumnName

Methods inherited from class com.netflix.hystrix.HystrixCommand

decomposeException, execute, getCacheKey, getCommandGroup, getCommandKey, getExecutionEvents, getExecutionTimeInMilliseconds, getFailedExecutionException, getFallback, getMetrics, getProperties, getThreadPoolKey, isCircuitBreakerOpen, isExecutedInThread, isExecutionComplete, isFailedExecution, isResponseFromCache, isResponseFromFallback, isResponseRejected, isResponseShortCircuited, isResponseTimedOut, isSuccessfulExecution, observe, queue, toObservable, toObservable

Methods inherited from class java.lang.Object

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

Constructor Detail

HystrixCassandraGetRowsByQuery

public HystrixCassandraGetRowsByQuery(com.netflix.astyanax.Keyspace keyspace,
                              com.netflix.astyanax.model.ColumnFamily<RowKeyType,java.lang.String> columnFamily,
                              java.lang.String cql)

Get rows specified by their row keys.

Parameters:

keyspace -

columnFamily -

cql -

HystrixCassandraGetRowsByQuery

public HystrixCassandraGetRowsByQuery(com.netflix.astyanax.Keyspace keyspace,
                              java.lang.String columnFamilyName,
                              java.lang.Class<?> columnFamilyKeyType,
                              java.lang.String cql)

Get rows specified by their row keys.

Parameters:

keyspace -

columnFamilyName -

cql -

Method Detail

run

protected com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String> run()
                                                                    throws java.lang.Exception

Specified by:

run in class com.netflix.hystrix.HystrixCommand<com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>>

Throws:

java.lang.Exception