bulk.rb in elasticsearch-api-1.0.18

- old
+ new

@@ -53,10 +53,11 @@
       # @option arguments [Boolean] :refresh Refresh the index after performing the operation
       # @option arguments [String]  :replication Explicitly set the replication type (options: sync, async)
       # @option arguments [Time]    :timeout Explicit operation timeout
       # @option arguments [String]  :fields Default comma-separated list of fields to return
       #                             in the response for updates
+      # @options arguments [String] :pipeline The pipeline ID to use for preprocessing incoming documents
       #
       # @return [Hash] Deserialized Elasticsearch response
       #
       # @see http://elasticsearch.org/guide/reference/api/bulk/
       #
@@ -69,10 +70,11 @@
           :consistency,
           :refresh,
           :replication,
           :type,
           :timeout,
-          :fields ]
+          :fields,
+          :pipeline ]
 
         method = HTTP_POST
         path   = Utils.__pathify Utils.__escape(arguments[:index]), Utils.__escape(type), '_bulk'
 
         params = Utils.__validate_and_extract_params arguments, valid_params