Class: Cassandra
Defined Under Namespace
Modules: Protocol
Instance Method Summary collapse
-
#get_indexed_slices(column_family, index_clause, *columns_and_options) ⇒ Object
Monkey patch get_indexed_slices so that it returns OrderedHash, otherwise cannot determine next start key when getting in chunks.
Instance Method Details
#get_indexed_slices(column_family, index_clause, *columns_and_options) ⇒ Object
Monkey patch get_indexed_slices so that it returns OrderedHash, otherwise cannot determine next start key when getting in chunks
49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 |
# File 'lib/right_support/db/cassandra_model.rb', line 49 def get_indexed_slices(column_family, index_clause, *) return false if Cassandra.VERSION.to_f < 0.7 column_family, columns, _, = extract_and_validate_params(column_family, [], , READ_DEFAULTS.merge(:key_count => 100, :key_start => "")) if index_clause.class != CassandraThrift::IndexClause index_expressions = index_clause.collect do |expression| create_index_expression(expression[:column_name], expression[:value], expression[:comparison]) end index_clause = create_index_clause(index_expressions, [:key_start], [:key_count]) end key_slices = _get_indexed_slices(column_family, index_clause, columns, [:count], [:start], [:finish], [:reversed], [:consistency]) key_slices.inject(OrderedHash.new){|h, key_slice| h[key_slice.key] = key_slice.columns; h} end |