class Pyper::Pipes::Cassandra::Deleter
@param table_name [Symbol] The table from which to delete @param client [Cassava::Client] client to query cassandra with
Public Instance Methods
pipe(arguments, status = {})
click to toggle source
@param status [Hash] The mutable status field @return [Hash] The original attributes
# File lib/pyper/pipes/cassandra/deleter.rb, line 10 def pipe(arguments, status = {}) local_args = arguments.dup columns = local_args.delete(:columns) statement = columns.present? ? client.delete(table_name, columns) : client.delete(table_name) statement.where(local_args).execute arguments end