78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
# File 'lib/elastic/core/connector.rb', line 78
def delete(_document)
raise ArgumentError, 'document must provide an id' unless _document['_id']
return if Elastic.config.disable_indexing
write_index, rolling_index = write_indices
operations = [{
'delete' => _document.merge('_index' => write_index, '_type' => DEFAULT_TYPE)
}]
if rolling_index
operations << {
'delete' => _document.merge('_index' => rolling_index, '_type' => DEFAULT_TYPE)
}
end
api.bulk(body: operations)
end
|