Manually commit and flush the batch indexing query
(self)
| 80 | self.commit() |
| 81 | |
| 82 | def commit(self): |
| 83 | """ |
| 84 | Manually commit and flush the batch indexing query |
| 85 | """ |
| 86 | self._pipeline.execute() |
| 87 | self.current_chunk = 0 |
| 88 | |
| 89 | def __init__(self, client, index_name="idx"): |
| 90 | """ |