本文整理了Java中org.elasticsearch.client.IndicesAdminClient.prepareDelete()
方法的一些代码示例,展示了IndicesAdminClient.prepareDelete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IndicesAdminClient.prepareDelete()
方法的具体详情如下:
包路径:org.elasticsearch.client.IndicesAdminClient
类名称:IndicesAdminClient
方法名:prepareDelete
[英]Deletes an index based on the index name.
[中]根据索引名称删除索引。
代码示例来源:origin: SonarSource/sonarqube
private void deleteIndex(String indexName) {
client.nativeClient().admin().indices().prepareDelete(indexName).get();
}
代码示例来源:origin: SonarSource/sonarqube
private void deleteIndex(String index) {
Loggers.get(getClass()).info("Drop Elasticsearch index [{}]", index);
client.nativeClient().admin().indices().prepareDelete(index).get();
}
}
代码示例来源: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: stagemonitor/stagemonitor
protected void deleteAll() {
node.client().admin().indices().prepareDelete("_all").get();
}
代码示例来源:origin: brianfrankcooper/YCSB
.isExists();
if (exists && newdb) {
client.admin().indices().prepareDelete(indexKey).execute().actionGet();
代码示例来源:origin: brianfrankcooper/YCSB
.isExists();
if (exists && newIndex) {
client.admin().indices().prepareDelete(indexKey).get();
代码示例来源:origin: apache/incubator-gobblin
@Override
public void recreateIndex(String indexName)
throws IOException {
DeleteIndexRequestBuilder dirBuilder = transportClient.admin().indices().prepareDelete(indexName);
try {
DeleteIndexResponse diResponse = dirBuilder.execute().actionGet();
} catch (IndexNotFoundException ie) {
System.out.println("Index not found... that's ok");
}
CreateIndexRequestBuilder cirBuilder = transportClient.admin().indices().prepareCreate(indexName);
CreateIndexResponse ciResponse = cirBuilder.execute().actionGet();
Assert.assertTrue(ciResponse.isAcknowledged(), "Create index succeeeded");
}
代码示例来源:origin: apache/usergrid
@Override
public void destroy() {
try {
logger.info( "dropping application keyspace" );
dataStaxCluster.getClusterSession()
.execute("DROP KEYSPACE "+ CQLUtils.quote(cassandraConfig.getApplicationKeyspace()));
dataStaxCluster.waitForSchemaAgreement();
logger.info( "dropping application local keyspace" );
dataStaxCluster.getClusterSession()
.execute("DROP KEYSPACE "+ CQLUtils.quote(cassandraConfig.getApplicationLocalKeyspace()));
dataStaxCluster.waitForSchemaAgreement();
dataStaxCluster.getClusterSession().close(); // close session so it's meta will get refreshed
}
catch ( Exception e ) {
logger.error("Error dropping application keyspaces: {} error: {}", cassandraConfig.getApplicationKeyspace(), e);
}
logger.info( "keyspaces dropped" );
logger.info( "dropping indices" );
final EsProvider provider =
SpringResource.getInstance().getBean( Injector.class ).getInstance( EsProvider.class );
provider.getClient().admin().indices().prepareDelete( "_all" ).execute().actionGet();
}
}
代码示例来源:origin: komoot/photon
public void deleteIndex() {
try {
this.getClient().admin().indices().prepareDelete("photon").execute().actionGet();
} catch (IndexNotFoundException e) {
// ignore
}
}
代码示例来源:origin: larsga/Duke
client.admin().indices().prepareDelete(this.indexName).execute()
.actionGet();
forceCreate = true;
代码示例来源:origin: com.github.tlrx/elasticsearch-test
@Override
public Void execute(Client client) throws ElasticsearchException {
client.admin().indices().prepareDelete(indices).execute().actionGet();
return null;
}
代码示例来源:origin: tlrx/elasticsearch-test
@Override
public Void execute(Client client) throws ElasticsearchException {
client.admin().indices().prepareDelete(indices).execute().actionGet();
return null;
}
代码示例来源:origin: jaibeermalik/searchanalytics-bigdata
@Override
public boolean deleteIndex(final String indexName) {
return searchClientService.getClient().admin().indices()
.prepareDelete(indexName).execute().actionGet()
.isAcknowledged();
}
代码示例来源:origin: org.sonarsource.sonarqube/sonar-server
private void deleteIndex(String index) {
Loggers.get(getClass()).info("Drop Elasticsearch index [{}]", index);
client.nativeClient().admin().indices().prepareDelete(index).get();
}
}
代码示例来源:origin: io.leopard/leopard-elasticsearch
@Override
public boolean clean(String indexName) {
try {
DeleteIndexResponse response = client.admin().indices().prepareDelete(indexName).execute().actionGet();
}
catch (IndexNotFoundException e) {
return false;
}
return true;
}
代码示例来源:origin: ff4j/ff4j
private void initNativeClient() {
esClient = NodeBuilder.nodeBuilder().client(true).node().client();
boolean indexExists = esClient.admin().indices().prepareExists(indexName).execute().actionGet().isExists();
if (indexExists) {
esClient.admin().indices().prepareDelete(indexName).execute().actionGet();
}
esClient.admin().indices().prepareCreate(indexName).execute().actionGet();
}
代码示例来源:origin: org.sonatype.nexus/nexus-repository
private void deleteIndex(final String indexName) {
bulkProcessor.flush(); // make sure dangling requests don't resurrect this index
IndicesAdminClient indices = indicesAdminClient();
if (indices.prepareExists(indexName).execute().actionGet().isExists()) {
indices.prepareDelete(indexName).execute().actionGet();
}
}
代码示例来源:origin: com.strapdata.elasticsearch.test/framework
static void cleanup(boolean resetNode) {
if (ElassandraDaemon.instance.node() != null) {
DeleteIndexRequestBuilder builder = ElassandraDaemon.instance.node().client().admin().indices().prepareDelete("*");
assertAcked(builder.get());
if (resetNode) {
reset();
}
}
}
public static String encodeBasicHeader(final String username, final String password) {
代码示例来源:origin: codelibs/elasticsearch-cluster-runner
public AcknowledgedResponse deleteIndex(final String index,
final BuilderCallback<DeleteIndexRequestBuilder> builder) {
final AcknowledgedResponse actionGet = builder
.apply(client().admin().indices().prepareDelete(index))
.execute().actionGet();
if (!actionGet.isAcknowledged()) {
onFailure("Failed to create " + index + ".", actionGet);
}
return actionGet;
}
代码示例来源:origin: jloisel/elastic-crud
@After
public void after() {
final IndicesAdminClient indices = client.admin().indices();
if(indices.prepareExists(INDEX).execute().actionGet().isExists()) {
indices.prepareDelete(INDEX).execute().actionGet();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!