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)