Add support for specifying a pipeline when indexing documents

Author: stof

lib/Elastica/Bulk/Action/IndexDocument.php

@@ -41,6 +41,7 @@ protected function _getMetadata(AbstractUpdateAction $action)
             'routing',
             'parent',
             'retry_on_conflict',
+            'pipeline',
         ];
 
         $metadata = $action->getOptions($params, true);

lib/Elastica/Client.php

@@ -403,6 +403,7 @@ public function updateDocument($id, $data, $index, $type, array $options = [])
                     'replication',
                     'refresh',
                     'timeout',
+                    'pipeline',
                 ]
             );
             $options += $docOptions;

lib/Elastica/Document.php

@@ -275,6 +275,34 @@ public function isAutoPopulate()
         return $this->_autoPopulate;
     }
 
+    /**
+     * Sets pipeline
+     *
+     * @param string $pipeline
+     *
+     * @return $this
+     */
+    public function setPipeline($pipeline)
+    {
+        return $this->setParam('_pipeline', $pipeline);
+    }
+
+    /**
+     * @return string
+     */
+    public function getPipeline()
+    {
+        return $this->getParam('_pipeline');
+    }
+
+    /**
+     * @return bool
+     */
+    public function hasPipeline()
+    {
+        return $this->hasParam('_pipeline');
+    }
+
     /**
      * Returns the document as an array.
      *

lib/Elastica/Type.php

@@ -82,6 +82,7 @@ public function addDocument(Document $doc)
                 'replication',
                 'refresh',
                 'timeout',
+                'pipeline',
             ]
         );