在ElasticSearch中提供了批量操作，下面是可能有帮助的文档https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html

您需要从应用程序中读取文件，遍历数组，并将每个文档发送到elasticsearch。
要执行最新的操作，应该使用bulk processor类。

BulkProcessor bulkProcessor = BulkProcessor.builder(
            (request, bulkListener) -> esClient.bulkAsync(request, RequestOptions.DEFAULT, bulkListener),
            new BulkProcessor.Listener() {
                @Override
                public void beforeBulk(long executionId, BulkRequest request) { }
                @Override
                public void afterBulk(long executionId, BulkRequest request, BulkResponse response) { }
                @Override
                public void afterBulk(long executionId, BulkRequest request, Throwable failure) { }
            })
            .setBulkActions(10000)
            .setFlushInterval(TimeValue.timeValueSeconds(5))
            .build();

对于每个 json 文件，电话：

bulkProcessor.add(new IndexRequest("INDEXNAME").source(json, XContentType.JSON));