org.elasticsearch.action.bulk.BulkRequest.refresh()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(1.8k)|赞(0)|评价(0)|浏览(289)

本文整理了Java中org.elasticsearch.action.bulk.BulkRequest.refresh()方法的一些代码示例,展示了BulkRequest.refresh()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。BulkRequest.refresh()方法的具体详情如下:
包路径:org.elasticsearch.action.bulk.BulkRequest
类名称:BulkRequest
方法名:refresh

BulkRequest.refresh介绍

[英]Should a refresh be executed post this bulk operation causing the operations to be searchable. Note, heavy indexing should not set this to true. Defaults to false.
[中]是否应在此批量操作后执行刷新,从而使操作可搜索。注意,重索引不应将其设置为true。默认为false。

代码示例

代码示例来源:origin: harbby/presto-connectors

/**
 * Should a refresh be executed post this bulk operation causing the operations to
 * be searchable. Note, heavy indexing should not set this to <tt>true</tt>. Defaults
 * to <tt>false</tt>.
 */
public BulkRequestBuilder setRefresh(boolean refresh) {
  request.refresh(refresh);
  return this;
}

代码示例来源:origin: mbok/logsniffer

@Override
  public Object execute(final Client client) {
    final BulkRequest deletes = new BulkRequest().refresh(true);
    for (final String id : eventIds) {
      for (final String index : indexNamingStrategy.getRetrievalNames(snifferId)) {
        deletes.add(new DeleteRequest(index, getType(snifferId), id));
      }
    }
    client.bulk(deletes).actionGet();
    logger.info("Deleted events: {}", (Object[]) eventIds);
    return null;
  }
});

代码示例来源:origin: harbby/presto-connectors

final ShardId shardId = entry.getKey();
final List<BulkItemRequest> requests = entry.getValue();
BulkShardRequest bulkShardRequest = new BulkShardRequest(bulkRequest, shardId, bulkRequest.refresh(), requests.toArray(new BulkItemRequest[requests.size()]));
bulkShardRequest.consistencyLevel(bulkRequest.consistencyLevel());
bulkShardRequest.timeout(bulkRequest.timeout());

代码示例来源:origin: harbby/presto-connectors

bulkRequest.refresh(request.paramAsBoolean("refresh", bulkRequest.refresh()));
bulkRequest.add(request.content(), defaultIndex, defaultType, defaultRouting, defaultFields, null, allowExplicitIndex);

相关文章