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