|
Elasticlient
|
Class for bulk document indexing. More...
#include <bulk.h>
Public Member Functions | |
| Bulk (const std::shared_ptr< Client > &client) | |
| Bulk (const std::vector< std::string > &hostUrlList, std::int32_t connectionTimeout) | |
| ~Bulk () | |
| Bulk (Bulk &&other) | |
| std::size_t | perform (const IBulkData &bulk) |
| std::size_t | getErrorCount () const |
| Return number of errors in last bulk being ran. | |
| const std::shared_ptr< Client > & | getClient () const |
| Return Client class with current config. | |
Class for bulk document indexing.
| elasticlient::Bulk::Bulk | ( | const std::shared_ptr< Client > & | client | ) |
| elasticlient::Bulk::Bulk | ( | const std::vector< std::string > & | hostUrlList, |
| std::int32_t | connectionTimeout | ||
| ) |
Initialize bulk indexer and creates Client instance for specified hostUrlList and connectionTimeout.
| hostUrlList | list of URLs of Elastic nodes in one cluster. |
| connectionTimeout | Elasticsearch node connection timeout. |
| elasticlient::Bulk::~Bulk | ( | ) |
Destroy bulk indexer, writing documents not yet indexed, discarding possible errors. If you are interested in errors, call flush() and getErrorCount() methods before destruction is made.
| std::size_t elasticlient::Bulk::perform | ( | const IBulkData & | bulk | ) |
Run the bulk.
1.8.17