Send with bulk processor and object mapper.

@param object the object
@param index  the index
@param type   the type
@param id     the id
349287
public void sendWithBulkProcessorAndObjectMapper(Object object,
            String index, String type, String id) {
        sendWithBulkProcessor(buildIndexRequest(index, type, id)
                .source(JMElasticsearchUtil.buildSourceByJsonMapper(object)));
    }
1139053
public void sendWithBulkProcessor(IndexRequest indexRequest) {
        Optional.ofNullable(this.bulkProcessor)
                .orElseGet(() -> setAndReturnBulkProcessor(BulkProcessor
                        .builder(jmESClient, bulkProcessorListener).build()))
                .add(indexRequest);
    }
1025360
public DeleteResponse deleteDoc(String index, String type, String id) {
		return deleteQuery(esClient.prepareDelete(index, type, id));
	}
1372562
public boolean deleteData(String indexName, String type, String id) {
        DeleteResponse response = getClient().prepareDelete().setIndex(indexName).setType(type).setId(id).execute().actionGet();
        return response.getResult() == DocWriteResponse.Result.DELETED;
    }
70030
public ActionFuture<UpdateResponse> upsertDataAsync(
            Map<String, ?> source, String index, String type, String id) {
        return upsertQueryAsync(buildPrepareUpsert(index, type, id, source));
    }
1205983
public UpdateResponse upsertDataWithObjectMapper(Object sourceObject,
            String index, String type, String id) {
        return upsertData(
                JMElasticsearchUtil.buildSourceByJsonMapper(sourceObject),
                index, type, id);
    }
775355
private void writeValue(String type, CmsUUID id, int index) {

        Locale locale = CmsLocaleManager.getLocale("en");
        // todo: check actual locale.
        m_document.addValue(m_cms, N_DETAIL_PAGE, locale, index);
        String typePath = N_DETAIL_PAGE + "[" + (1 + index) + "]/" + N_TYPE;
        I_CmsXmlContentValue typeVal = m_document.getValue(typePath, locale);
        String pagePath = N_DETAIL_PAGE + "[" + (1 + index) + "]/" + N_PAGE;
        CmsXmlVfsFileValue pageVal = (CmsXmlVfsFileValue)m_document.getValue(pagePath, locale);
        typeVal.setStringValue(m_cms, type);
        pageVal.setIdValue(m_cms, id);
    }
742761
function(index) {
      var that = this;

      return this.readByIndex(index).then(function(doc) {
        return that.delete(doc[that._dbType.id]);
      });
    }
32856
public void clearIndex(Index index) {
    BulkIndexer.delete(esClient, IndexType.main(index, index.getName()), esClient.prepareSearch(index).setQuery(matchAllQuery()));
  }
1139832
public IndexResponse sendData(Map<String, ?> source, String index,
            String type, String id) {
        return indexQuery(buildIndexRequest(source, index, type, id));
    }
795096
public String sendData(Map<String, ?> source, String index,
            String type) {
        return sendData(source, index, type, null).getId();
    }
341848
public void createOrUpdateData(String indexName, String type, List<NutMap> list) {
        BulkRequestBuilder bulkRequest = getClient().prepareBulk();
        if (list.size() > 0) {
            for (NutMap nutMap : list) {
                bulkRequest.add(getClient().prepareIndex(indexName, type).setId(nutMap.getString("id")).setSource(Lang.obj2map(nutMap.get("obj"))));
            }
            bulkRequest.execute().actionGet();
        }
    }
1051315
public Binder collect(int index, Class<?> type) {
        return new Binder(this, new Collect(type(), index, type));
    }
263430
public void updateObjectId(String objectId) {
        if (configForVM != null) {
            configForVM.withObjectId(objectId);
        } else {
            configForAppService.withObjectId(objectId);
        }
    }
310813
public void deleteBulkDocsAsync(String index, String type,
            ActionListener<BulkResponse> bulkResponseActionListener) {
        executeBulkRequestAsync(
                buildDeleteBulkRequestBuilder(
                        buildAllDeleteRequestBuilderList(index, type)),
                bulkResponseActionListener);
    }
847854
public SearchResponse searchAll(String index, String type) {
        return searchAll(JMArrays.buildArray(index), type);
    }
733
void update(long index, Instant instant, Type type) {
    this.index = index;
    this.type = type;
    clock.set(instant);
  }