Class: CassandraMapper::Persistence::ClassMethods::SimpleMutator

Inherits:

Object

• Object
• CassandraMapper::Persistence::ClassMethods::SimpleMutator

Defined in:

lib/cassandra_mapper/persistence.rb

Instance Method Summary

• #from_simple(structure, timestamp) ⇒ Object

Instance Method Details

#from_simple(structure, timestamp) ⇒ Object

# File 'lib/cassandra_mapper/persistence.rb', line 225

def from_simple(structure, timestamp)
  deletion = nil
  deletion_columns = nil
  structure.inject([]) do |list, pair|
    key,val = pair
    if val.nil?
      unless deletion
        deletion = CassandraThrift::Mutation.new(
          :deletion => CassandraThrift::Deletion.new(
            :super_column => nil,
            :timestamp    => timestamp,
            :predicate    => CassandraThrift::SlicePredicate.new(
              :column_names => (deletion_columns = [])
            )
          )
        )
        list << deletion
      end
      deletion_columns << key
    else
      list << CassandraThrift::Mutation.new(
        :column_or_supercolumn => CassandraThrift::ColumnOrSuperColumn.new(
          :column => CassandraThrift::Column.new(
            :name      => key,
            :value     => val,
            :timestamp => timestamp
          )
        )
      )
    end
    list
  end
end