本文整理了Java中org.elasticsearch.action.bulk.BulkRequest.refresh()
方法的一些代码示例,展示了BulkRequest.refresh()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。BulkRequest.refresh()
方法的具体详情如下:
包路径:org.elasticsearch.action.bulk.BulkRequest
类名称: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);
内容来源于网络,如有侵权,请联系作者删除!