Class: ActiveColumn::Tasks::ColumnFamily
- Inherits:
-
Object
- Object
- ActiveColumn::Tasks::ColumnFamily
- Defined in:
- lib/active_column/tasks/column_family.rb
Constant Summary collapse
- COMPARATOR_TYPES =
{ :time => 'TimeUUIDType', :timestamp => 'TimeUUIDType', :long => 'LongType', :string => 'BytesType' }
Instance Method Summary collapse
- #clear(name) ⇒ Object
- #create(name, options = {}) ⇒ Object
- #drop(name) ⇒ Object
- #exists?(name) ⇒ Boolean
-
#initialize ⇒ ColumnFamily
constructor
A new instance of ColumnFamily.
Constructor Details
#initialize ⇒ ColumnFamily
Returns a new instance of ColumnFamily.
12 13 14 |
# File 'lib/active_column/tasks/column_family.rb', line 12 def initialize @cassandra = ActiveColumn.connection end |
Instance Method Details
#clear(name) ⇒ Object
33 34 35 |
# File 'lib/active_column/tasks/column_family.rb', line 33 def clear(name) @cassandra.truncate!(name.to_s) end |
#create(name, options = {}) ⇒ Object
20 21 22 23 24 25 26 27 |
# File 'lib/active_column/tasks/column_family.rb', line 20 def create(name, = {}) opts = { :name => name.to_s, :keyspace => @cassandra.keyspace, :comparator_type => 'TimeUUIDType' }.merge() cf = Cassandra::ColumnFamily.new.with_fields(opts) @cassandra.add_column_family(cf) end |
#drop(name) ⇒ Object
29 30 31 |
# File 'lib/active_column/tasks/column_family.rb', line 29 def drop(name) @cassandra.drop_column_family(name.to_s) end |
#exists?(name) ⇒ Boolean
16 17 18 |
# File 'lib/active_column/tasks/column_family.rb', line 16 def exists?(name) @cassandra.schema.cf_defs.find { |cf_def| cf_def.name == name.to_s } end |