적용버전

  • ES 2.4.1
  • ES Transport Client in JAVA

ES에 delete by query plugin 설치

$ sudo bin/plugin install delete-by-query

ES Client 설정 자바코드

TransportClient.builder() //
    .settings(settings) //
    .addPlugin(DeleteByQueryPlugin.class) //
    .build()
    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(ES_HOST), ES_PORT));

Delete By Query 자바코드

String query = "{" +
    "  \"query\": { " +
    "    \"term\": {" +
    "      \"dongNo\": \"" + dongNo + "\"" +
    "    }" +
    "  }" +
    "}";

new DeleteByQueryRequestBuilder(client, DeleteByQueryAction.INSTANCE)
    .setIndices(EsConfig.INDEX_ALIAS_NAME)
    .setTypes(EsConfig.TYPE_NAME)
    .setSource(query)
    .execute()
    .get();

SENSE 버전

DELETE /price/info/_query
{
  "query": {
    "term": {
      "siName": {
        "value": "충청북도"
      }
    }
  }
}