本文整理了Java中org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse.<init>()
方法的一些代码示例,展示了DeleteIndexResponse.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DeleteIndexResponse.<init>()
方法的具体详情如下:
包路径:org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse
类名称:DeleteIndexResponse
方法名:<init>
暂无
代码示例来源:origin: harbby/presto-connectors
@Override
protected DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: harbby/presto-connectors
@Override
public DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
protected DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: apache/servicemix-bundles
public static DeleteIndexResponse fromXContent(XContentParser parser) {
return new DeleteIndexResponse(parseAcknowledged(parser));
}
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public void onResponse(ClusterStateUpdateResponse response) {
listener.onResponse(new DeleteIndexResponse(response.isAcknowledged()));
}
代码示例来源:origin: harbby/presto-connectors
@Override
public void onResponse(MetaDataDeleteIndexService.Response response) {
listener.onResponse(new DeleteIndexResponse(response.acknowledged()));
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
protected void masterOperation(final DeleteIndexRequest request, final ClusterState state, final ActionListener<DeleteIndexResponse> listener) {
final Set<Index> concreteIndices = new HashSet<>(Arrays.asList(indexNameExpressionResolver.concreteIndices(state, request)));
if (concreteIndices.isEmpty()) {
listener.onResponse(new DeleteIndexResponse(true));
return;
}
DeleteIndexClusterStateUpdateRequest deleteRequest = new DeleteIndexClusterStateUpdateRequest()
.ackTimeout(request.timeout()).masterNodeTimeout(request.masterNodeTimeout())
.indices(concreteIndices.toArray(new Index[concreteIndices.size()]));
deleteIndexService.deleteIndices(deleteRequest, new ActionListener<ClusterStateUpdateResponse>() {
@Override
public void onResponse(ClusterStateUpdateResponse response) {
listener.onResponse(new DeleteIndexResponse(response.isAcknowledged()));
}
@Override
public void onFailure(Exception t) {
logger.debug((Supplier<?>) () -> new ParameterizedMessage("failed to delete indices [{}]", concreteIndices), t);
listener.onFailure(t);
}
});
}
}
代码示例来源:origin: harbby/presto-connectors
@Override
protected void masterOperation(final DeleteIndexRequest request, final ClusterState state, final ActionListener<DeleteIndexResponse> listener) {
final String[] concreteIndices = indexNameExpressionResolver.concreteIndices(state, request);
if (concreteIndices.length == 0) {
listener.onResponse(new DeleteIndexResponse(true));
return;
}
deleteIndexService.deleteIndices(new MetaDataDeleteIndexService.Request(concreteIndices).timeout(request.timeout()).masterTimeout(request.masterNodeTimeout()), new MetaDataDeleteIndexService.Listener() {
@Override
public void onResponse(MetaDataDeleteIndexService.Response response) {
listener.onResponse(new DeleteIndexResponse(response.acknowledged()));
}
@Override
public void onFailure(Throwable t) {
listener.onFailure(t);
}
});
}
}
内容来源于网络,如有侵权,请联系作者删除!