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