com.netflix.nicobar.cassandra.internal

Class HystrixCassandraGetRowsByKeys<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.HystrixCassandraGetRowsByKeys<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 HystrixCassandraGetRowsByKeys<RowKeyType>
extends AbstractCassandraHystrixCommand<com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>>

Hystrix command to get rows from Cassandra specified by a set of row keys. 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
HystrixCassandraGetRowsByKeys(com.netflix.astyanax.Keyspace keyspace, java.lang.String columnFamilyName, RowKeyType... rowKeys)

Method Summary

Methods

Modifier and Type	Method and Description
protected com.netflix.astyanax.model.Rows<RowKeyType,java.lang.String>	run()
HystrixCassandraGetRowsByKeys<RowKeyType>	withColumns(java.lang.String... columns) Restrict the response to only these columns.

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

HystrixCassandraGetRowsByKeys

public HystrixCassandraGetRowsByKeys(com.netflix.astyanax.Keyspace keyspace,
                             java.lang.String columnFamilyName,
                             RowKeyType... rowKeys)

Method Detail

withColumns

public HystrixCassandraGetRowsByKeys<RowKeyType> withColumns(java.lang.String... columns)

Restrict the response to only these columns. Example usage: new HystrixCassandraGetRow(args).withColumns("column1", "column2").execute()

Parameters:

columns - list of column names.

Returns:

result row sets.

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