class Pyper::Pipes::Cassandra::Writer

@param table_name [Symbol] The table in which to store the attributes @param client [Cassava::Client] client to query cassandra with @param attribute_filter_set [Set] Optionally, a set of attributes which should be written. If none is provided,

all attributes will be written.

Public Instance Methods

pipe(attributes, status = {}) click to toggle source

@param args [Hash] Arguments to store in cassandra @param status [Hash] The mutable status field @return [Hash] The original attributes

# File lib/pyper/pipes/cassandra/writer.rb, line 13
def pipe(attributes, status = {})
  attributes_to_write = if attribute_filter_set
                          attributes.select { |k,v| attribute_filter_set.member?(k) }
                        else
                          attributes
                        end

  client.insert(table_name, attributes_to_write)
  attributes
end