com.netflix.nicobar.cassandra.internal

Class HystrixCassandraGetRow<RowKeyType>

java.lang.Object

com.netflix.hystrix.HystrixCommand<K>

com.netflix.nicobar.cassandra.internal.AbstractCassandraHystrixCommand<com.netflix.astyanax.model.ColumnList<java.lang.String>>

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

Type Parameters:

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

All Implemented Interfaces:

com.netflix.hystrix.HystrixExecutable<com.netflix.astyanax.model.ColumnList<java.lang.String>>

public class HystrixCassandraGetRow<RowKeyType>
extends AbstractCassandraHystrixCommand<com.netflix.astyanax.model.ColumnList<java.lang.String>>

Hystrix command to get a row from Cassandra using a specific row key.

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
HystrixCassandraGetRow(com.netflix.astyanax.Keyspace keyspace, com.netflix.astyanax.model.ColumnFamily<RowKeyType,java.lang.String> columnFamily, RowKeyType rowKey)
HystrixCassandraGetRow(com.netflix.astyanax.Keyspace keyspace, java.lang.String columnFamilyName, RowKeyType rowKey)

Method Summary

Methods

Modifier and Type	Method and Description
protected com.netflix.astyanax.model.ColumnList<java.lang.String>	run()
HystrixCassandraGetRow<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

HystrixCassandraGetRow

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

HystrixCassandraGetRow

public HystrixCassandraGetRow(com.netflix.astyanax.Keyspace keyspace,
                      java.lang.String columnFamilyName,
                      RowKeyType rowKey)

Method Detail

withColumns

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

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

Parameters:

columns - the list of column names.

Returns:

self.

run

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

Specified by:

run in class com.netflix.hystrix.HystrixCommand<com.netflix.astyanax.model.ColumnList<java.lang.String>>

Throws:

java.lang.Exception