This is an automated email from the ASF dual-hosted git repository.
sebb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-ponymail-foal.git
The following commit(s) were added to refs/heads/master by this push:
new bb3f789 Allow use of streaming_bulk
bb3f789 is described below
commit bb3f789b3a82ae3c6782942a8dc347d94e33a227
Author: Sebb <[email protected]>
AuthorDate: Fri Jan 14 22:58:12 2022 +0000
Allow use of streaming_bulk
---
tools/plugins/elastic.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/tools/plugins/elastic.py b/tools/plugins/elastic.py
index a24c641..63a20e6 100755
--- a/tools/plugins/elastic.py
+++ b/tools/plugins/elastic.py
@@ -188,6 +188,9 @@ class Elastic:
def bulk(self, actions, **kwargs):
return helpers.bulk(self.es, actions, **kwargs)
+ def streaming_bulk(self, actions, **kwargs):
+ return helpers.streaming_bulk(self.es, actions, **kwargs)
+
def clear_scroll(self, *args, **kwargs):
"""
Call this to release the scroll id and its resources