本文整理了Java中org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse
类的一些代码示例,展示了DeleteIndexResponse
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DeleteIndexResponse
类的具体详情如下:
包路径:org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse
类名称:DeleteIndexResponse
[英]A response for a delete index action.
[中]对删除索引操作的响应。
代码示例来源:origin: SonarSource/sonarqube
private static void deleteIndexIfExists(String name) {
try {
DeleteIndexResponse response = SHARED_NODE.client().admin().indices().prepareDelete(name).get();
checkState(response.isAcknowledged(), "Fail to drop the index " + name);
} catch (IndexNotFoundException e) {
// ignore
}
}
代码示例来源:origin: harbby/presto-connectors
@Override
public DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: apache/servicemix-bundles
public static DeleteIndexResponse fromXContent(XContentParser parser) {
return new DeleteIndexResponse(parseAcknowledged(parser));
}
}
代码示例来源:origin: harbby/presto-connectors
@Override
public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out);
writeAcknowledged(out);
}
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public void readFrom(StreamInput in) throws IOException {
super.readFrom(in);
readAcknowledged(in);
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out);
writeAcknowledged(out);
}
}
代码示例来源:origin: harbby/presto-connectors
@Override
public void readFrom(StreamInput in) throws IOException {
super.readFrom(in);
readAcknowledged(in);
}
代码示例来源:origin: com.strapdata.elasticsearch.test/framework
public static void assertAcked(DeleteIndexResponse response) {
assertThat("Delete Index failed - not acked", response.isAcknowledged(), equalTo(true));
assertVersionSerializable(response);
}
代码示例来源:origin: harbby/presto-connectors
@Override
protected DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: com.netflix.raigad/raigad
/**
* Courtesy Jae Bae
*/
public void deleteIndices(Client client, String indexName, int timeout) {
logger.info("trying to delete " + indexName);
DeleteIndexResponse deleteIndexResponse = client.admin().indices().prepareDelete(indexName).execute().actionGet(timeout);
if (!deleteIndexResponse.isAcknowledged()) {
throw new RuntimeException("INDEX DELETION FAILED");
} else {
logger.info(indexName + " deleted");
}
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
protected DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: javanna/elasticshell
@Override
protected XContentBuilder toXContent(DeleteIndexRequest request, DeleteIndexResponse response, XContentBuilder builder) throws IOException {
return builder.startObject()
.field(Fields.OK, true)
.field(Fields.ACKNOWLEDGED, response.isAcknowledged())
.endObject();
}
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public DeleteIndexResponse newResponse() {
return new DeleteIndexResponse();
}
代码示例来源:origin: jaibeermalik/searchanalytics-bigdata
@Override
public boolean deleteIndex(final String indexName) {
return searchClientService.getClient().admin().indices()
.prepareDelete(indexName).execute().actionGet()
.isAcknowledged();
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public void onResponse(ClusterStateUpdateResponse response) {
listener.onResponse(new DeleteIndexResponse(response.isAcknowledged()));
}
代码示例来源:origin: arey/spring-batch-toolkit
@Override
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
try {
DeleteIndexResponse response = esClient.admin().indices().prepareDelete(indexName).execute().actionGet();
if (!response.isAcknowledged()) {
throw new RuntimeException("Index deletion has not been acknowledged");
}
LOG.info("Index {} deleted", indexName);
} catch (IndexNotFoundException e) {
LOG.info("The index {} does not exist. Thus nothing to delete.", indexName);
}
return RepeatStatus.FINISHED;
}
代码示例来源:origin: harbby/presto-connectors
@Override
public void onResponse(MetaDataDeleteIndexService.Response response) {
listener.onResponse(new DeleteIndexResponse(response.acknowledged()));
}
代码示例来源:origin: souyunku/SpringBootExamples
/**
* 删除索引
*
* @param index
* @return
*/
public static boolean deleteIndex(String index) {
if (!isIndexExist(index)) {
LOGGER.info("Index is not exits!");
}
DeleteIndexResponse dResponse = client.admin().indices().prepareDelete(index).execute().actionGet();
if (dResponse.isAcknowledged()) {
LOGGER.info("delete index " + index + " successfully!");
} else {
LOGGER.info("Fail to delete index " + index);
}
return dResponse.isAcknowledged();
}
代码示例来源: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: jaibeermalik/elasticsearch-tutorial
@Override
public boolean deleteIndex(String indexName)
{
return searchClientService.getClient().admin().indices().prepareDelete(indexName).execute().actionGet().isAcknowledged();
}
内容来源于网络,如有侵权,请联系作者删除!