Uses of Class
lumis.portal.bigdata.elasticsearch.BulkProcessor

Packages that use BulkProcessor

Package	Description
lumis.portal.bigdata.elasticsearch	lumis.portal.bigdata implementation for using Elasticsearch.

Uses of BulkProcessor in lumis.portal.bigdata.elasticsearch

Fields in lumis.portal.bigdata.elasticsearch declared as BulkProcessor

Modifier and Type	Field and Description
protected BulkProcessor	ElasticsearchRepository.bulkProcessor The BulkProcessor instance shared with IBatchIndexer generated by this repository.

Methods in lumis.portal.bigdata.elasticsearch that return BulkProcessor

Modifier and Type	Method and Description
BulkProcessor	BulkProcessor.add(org.elasticsearch.common.bytes.BytesReference data, String defaultIndex, String defaultType, String defaultPipeline, org.elasticsearch.common.xcontent.XContentType xContentType) Adds the data from the bytes to be processed by the bulk processor
BulkProcessor	BulkProcessor.add(org.elasticsearch.common.bytes.BytesReference data, String defaultIndex, String defaultType, org.elasticsearch.common.xcontent.XContentType xContentType) Adds the data from the bytes to be processed by the bulk processor
BulkProcessor	BulkProcessor.add(org.elasticsearch.action.delete.DeleteRequest request) Adds an DeleteRequest to the list of actions to execute.
BulkProcessor	BulkProcessor.add(org.elasticsearch.action.DocWriteRequest<?> request) Adds either a delete or an index request.
BulkProcessor	BulkProcessor.add(org.elasticsearch.action.index.IndexRequest request) Adds an IndexRequest to the list of actions to execute.
BulkProcessor	ElasticsearchRepository.getBulkProcessor() Returns an internal bulk processor used by this repository.