Elasticsearch 2.0: come eliminare per query in Java

Question

Sto tentando di eseguire l'aggiornamento a ES 2.0. Ho scaricato ES 2.0 e l'ho installato sulla mia macchina Windows.

Nel mio pom.xml, ho il seguente:

<dependency> 
    <groupId>org.elasticsearch</groupId> 
    <artifactId>elasticsearch</artifactId> 
    <version>2.0.0-rc1</version> 
</dependency> 

<dependency> 
    <groupId>org.elasticsearch.plugin</groupId> 
    <artifactId>delete-by-query</artifactId> 
    <version>2.0.0-rc1</version> 
</dependency> 

Nel mio codice Java, ho fatto cancellare dalla query nel seguente modo quando si utilizza ES 1.7.3:

StringBuilder b = new StringBuilder(""); 
    b.append("{"); 
    b.append(" \"query\": {"); 
    b.append("  \"term\": {"); 
    b.append("   \"category\": " + category_value); 
    b.append("  }"); 
    b.append(" }"); 
    b.append("}"); 

    client = getClient(); 

    DeleteByQueryResponse response = client.prepareDeleteByQuery("myindex") 
       .setTypes("mydocytype") 
       .setSource(b.toString()) 
       .execute() 
       .actionGet(); 

Spero di sostituire questo:

DeleteByQueryResponse response = client.prepareDeleteByQuery("myindex") 
       .setTypes("mydocytype") 
       .setSource(b.toString()) 
       .execute() 
       .actionGet(); 

con ES 2.0 modo. Cercata su Google ma non è riuscito a trovare un esempio per questo. La documentazione dell'API online mi sembra troppo astratta. Come posso farlo?

Un'altra domanda: devo installare il plug-in delete-by-query nel server Elasticsearch?

Grazie per qualsiasi puntatore!

UPDATE

ho seguito il suggerimento di Max, e qui è quello che ho adesso:

In primo luogo, quando si crea il cliente, effettuare le impostazioni hanno il seguente aspetto:

Settings settings = Settings.settingsBuilder() 
         .put("cluster.name", "mycluster") 
         .put("plugin.types", DeleteByQueryPlugin.class.getName()) 
         .build(); 

Seconda , nel posto in cui viene eseguita la cancellazione per query:

DeleteByQueryResponse rsp = new DeleteByQueryRequestBuilder(client, DeleteByQueryAction.INSTANCE) 
    .setIndices("myindex") 
    .setTypes("mydoctype") 
    .setSource(b.toString()) 
    .execute() 
    .actionGet(); 

ho installato anche cancellare dal plugin di ricerca eseguendo il seguente nella directory principale di ES:

bin\plugin install delete-by-query 

ottengo errori se non installare questo plugin.

Dopo tutti questi passaggi, le parti correlate a ES funzionano perfettamente.

Answer 1

io credo che si possa usare questo:

 DeleteByQueryResponse rsp = new DeleteByQueryRequestBuilder(client, DeleteByQueryAction.INSTANCE) 
      .setTypes("mydocytype") 
      .setSource(b.toString()) 
      .execute() 
      .actionGet(); 

si deve aggiungere il tipo plugin per le impostazioni:

 Settings settings = Settings.settingsBuilder() 
         .put("plugin.types", DeleteByQueryPlugin.class.getName()) 

Se si dispone di server remoto è necessario installare il plugin.

Answer 2

plugin.types sono stati deprecati in ES 2.1.0 (source). Quindi la soluzione accettata risulterà in un NullPointerException.

La soluzione è quella di utilizzare il metodo addPlugin:

Client client = TransportClient.builder().settings(settings()) 
       .addPlugin(DeleteByQueryPlugin.class) 
       .build() 
       .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host",9300)); 

Answer 3

innanzitutto: aggiungere elasticsearch-2.3.3/plugins/delete-by-query/delete-by-query-2.3.3.jar a costruire il percorso.

poi:

Client client = TransportClient.builder().settings(settings) 
       .addPlugin(DeleteByQueryPlugin.class) 
       .build() 
       .addTransportAddress(new InetSocketTransportAddress(
         InetAddress.getByName("192.168.0.224"), 9300)); 

Answer 4

Da elastico 5 in poi ...

final BulkIndexByScrollResponse response = DeleteByQueryAction.INSTANCE.newRequestBuilder(super.transportClient) 
        .filter(
          QueryBuilders.boolQuery() 
            .must(QueryBuilders.termQuery("_type", "MY_TYPE")) // Trick to define and ensure the type. 
            .must(QueryBuilders.termQuery("...", "..."))) 
        .source("MY_INDEX") 
        .get(); 

    return response.getDeleted() > 0; 

Oficial documentation