org.elasticsearch.client.IndicesAdminClient.prepareDelete()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(202)

本文整理了Java中org.elasticsearch.client.IndicesAdminClient.prepareDelete()方法的一些代码示例,展示了IndicesAdminClient.prepareDelete()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IndicesAdminClient.prepareDelete()方法的具体详情如下:
包路径:org.elasticsearch.client.IndicesAdminClient
类名称:IndicesAdminClient
方法名:prepareDelete

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();
  }
 }
}

相关文章

微信公众号

最新文章

更多

IndicesAdminClient类方法