적용버전
- 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": "충청북도"
}
}
}
}