lib/elasticsearch/api/actions/bulk.rb in elasticsearch-api-8.0.0.pre1 vs lib/elasticsearch/api/actions/bulk.rb in elasticsearch-api-8.0.0
- old
+ new
@@ -19,11 +19,10 @@
module API
module Actions
# Allows to perform multiple index/update/delete operations in a single request.
#
# @option arguments [String] :index Default index for items which don't provide one
- # @option arguments [String] :type Default document type for items which don't provide one
# @option arguments [String] :wait_for_active_shards Sets the number of shard copies that must be active before proceeding with the bulk operation. Defaults to 1, meaning the primary shard only. Set to `all` for all shard copies, otherwise set to any non-negative value less than or equal to the total number of copies for the shard (number of replicas + 1)
# @option arguments [String] :refresh If `true` then refresh the affected shards to make this operation visible to search, if `wait_for` then wait for a refresh to make this operation visible to search, if `false` (the default) then do nothing with refreshes. (options: true, false, wait_for)
# @option arguments [String] :routing Specific routing value
# @option arguments [Time] :timeout Explicit operation timeout
# @option arguments [List] :_source True or false to return the _source field or not, or default list of fields to return, can be overridden on each sub-request
@@ -46,15 +45,11 @@
arguments = arguments.clone
_index = arguments.delete(:index)
- _type = arguments.delete(:type)
-
method = Elasticsearch::API::HTTP_POST
- path = if _index && _type
- "#{Utils.__listify(_index)}/#{Utils.__listify(_type)}/_bulk"
- elsif _index
+ path = if _index
"#{Utils.__listify(_index)}/_bulk"
else
"_bulk"
end
params = Utils.process_params(arguments)