es范围删除java代码

以下是一个使用Java API在Elasticsearch中进行范围删除的示例代码：

import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.DeleteIndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.client.RestClient;

import java.io.IOException;

public class RangeDeleteExample {
    
    public static void main(String[] args) throws IOException {
        // 创建Elasticsearch客户端
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost("localhost", 9200, "http")));
        
        // 创建一个BulkRequest，用于添加删除请求
        BulkRequest bulkRequest = new BulkRequest();
        bulkRequest.timeout("2m"); // 设置超时时间
        
        // 添加删除请求，使用Range Query来查询需要删除的文档
        bulkRequest.add(new DeleteRequest("index_name").setPipeline("pipeline_name")
                .setQuery(QueryBuilders.rangeQuery("timestamp")
                        .gte("2019-01-01").lte("2019-12-31")));
        
        // 执行BulkRequest并获取响应
        BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
        
        // 处理响应结果
        if (bulkResponse.hasFailures()) {
            // 处理删除失败的情况
            System.out.println("删除失败：" + bulkResponse.buildFailureMessage());
        } else {
            // 处理删除成功的情况
            System.out.println("删除成功！");
        }
        
        // 关闭Elasticsearch客户端
        client.close();
    }
}

注意，这里使用了Bulk API来批量处理删除请求，以提高删除效率。另外，还可以使用管道（Pipeline）来预处理删除请求，例如，可以在管道中添加一些转换操作或过滤操作，以便更精准地控制删除的范围和内容。