本文整理了Java中org.elasticsearch.client.Requests.deleteIndexRequest
方法的一些代码示例,展示了Requests.deleteIndexRequest
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Requests.deleteIndexRequest
方法的具体详情如下:
包路径:org.elasticsearch.client.Requests
类名称:Requests
方法名:deleteIndexRequest
[英]Creates a delete index request.
[中]创建删除索引请求。
代码示例来源:origin: ezbz/projectx
@Override
public ActionFuture<DeleteIndexResponse> execute(final IndicesAdminClient admin) {
return admin.delete(Requests.deleteIndexRequest(indexName));
}
});
代码示例来源:origin: SeaseLtd/rated-ranking-evaluator
proxy.admin().indices().delete(deleteIndexRequest(indexName)).actionGet();
代码示例来源:origin: apache/streams
@BeforeClass
public void prepareTestPersistWriter() throws Exception {
testConfiguration = new ComponentConfigurator<>(ElasticsearchWriterConfiguration.class).detectConfiguration("ElasticsearchPersistWriterIT");
testClient = ElasticsearchClientManager.getInstance(testConfiguration).client();
ClusterHealthRequest clusterHealthRequest = Requests.clusterHealthRequest();
ClusterHealthResponse clusterHealthResponse = testClient.admin().cluster().health(clusterHealthRequest).actionGet();
assertNotEquals(clusterHealthResponse.getStatus(), ClusterHealthStatus.RED);
IndicesExistsRequest indicesExistsRequest = Requests.indicesExistsRequest(testConfiguration.getIndex());
IndicesExistsResponse indicesExistsResponse = testClient.admin().indices().exists(indicesExistsRequest).actionGet();
if(indicesExistsResponse.isExists()) {
DeleteIndexRequest deleteIndexRequest = Requests.deleteIndexRequest(testConfiguration.getIndex());
DeleteIndexResponse deleteIndexResponse = testClient.admin().indices().delete(deleteIndexRequest).actionGet();
assertTrue(deleteIndexResponse.isAcknowledged());
}
}
代码示例来源:origin: apache/streams
@BeforeClass
public void prepareTestParentChildPersistWriter() throws Exception {
testConfiguration = new ComponentConfigurator<>(ElasticsearchWriterConfiguration.class).detectConfiguration("ElasticsearchParentChildWriterIT");
testClient = ElasticsearchClientManager.getInstance(testConfiguration).client();
ClusterHealthRequest clusterHealthRequest = Requests.clusterHealthRequest();
ClusterHealthResponse clusterHealthResponse = testClient.admin().cluster().health(clusterHealthRequest).actionGet();
assertNotEquals(clusterHealthResponse.getStatus(), ClusterHealthStatus.RED);
IndicesExistsRequest indicesExistsRequest = Requests.indicesExistsRequest(testConfiguration.getIndex());
IndicesExistsResponse indicesExistsResponse = testClient.admin().indices().exists(indicesExistsRequest).actionGet();
if (indicesExistsResponse.isExists()) {
DeleteIndexRequest deleteIndexRequest = Requests.deleteIndexRequest(testConfiguration.getIndex());
DeleteIndexResponse deleteIndexResponse = testClient.admin().indices().delete(deleteIndexRequest).actionGet();
assertTrue(deleteIndexResponse.isAcknowledged());
}
PutIndexTemplateRequestBuilder putTemplateRequestBuilder = testClient.admin().indices().preparePutTemplate("mappings");
URL templateURL = ElasticsearchParentChildWriterIT.class.getResource("/ActivityChildObjectParent.json");
ObjectNode template = MAPPER.readValue(templateURL, ObjectNode.class);
String templateSource = MAPPER.writeValueAsString(template);
putTemplateRequestBuilder.setSource(templateSource);
testClient.admin().indices().putTemplate(putTemplateRequestBuilder.request()).actionGet();
Reflections reflections = new Reflections(new ConfigurationBuilder()
.setUrls(ClasspathHelper.forPackage("org.apache.streams.pojo.json"))
.setScanners(new SubTypesScanner()));
objectTypes = reflections.getSubTypesOf(ActivityObject.class);
Path testdataDir = Paths.get("target/dependency/activitystreams-testdata");
files = Files.list(testdataDir).collect(Collectors.toList());
assert( files.size() > 0);
}
代码示例来源:origin: apache/streams
IndicesExistsResponse indicesExistsResponse = testClient.admin().indices().exists(indicesExistsRequest).actionGet();
if(indicesExistsResponse.isExists()) {
DeleteIndexRequest deleteIndexRequest = Requests.deleteIndexRequest(testConfiguration.getIndex());
DeleteIndexResponse deleteIndexResponse = testClient.admin().indices().delete(deleteIndexRequest).actionGet();
内容来源于网络,如有侵权,请联系作者删除!