Method: Dataflow::Adapters::MongoDbAdapter#delete

Defined in:

lib/dataflow/adapters/mongo_db_adapter.rb

#delete(where: {}) ⇒ Object

Delete records that match the options.

Parameters:

• where (defaults to: {}) —

  query to apply on the delete operation.

# File 'lib/dataflow/adapters/mongo_db_adapter.rb', line 169

def delete(where: {})
  client[read_dataset_name].delete_many(transform_to_query(where))
end