但是当我尝试创建BulkProcessor时，我遇到了一个问题，我不知道如何将这个示例从Java转换为Scala
`BulkProcessor.Builder builder = BulkProcessor.builder[org.elasticsearch.action.bulk.BulkResponse]],x$2: org.elasticsearch.action.bulk.BulkProcessor.Listener)org.elasticsearch.acti
浏览 8提问于2018-02-03得票数 1
1回答
$AsyncBulkRequestHandler.execute(BulkRequestHandler.java:121) at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:312) at org.elasticsearch.action.bulk.BulkProcessor.executeIfNeeded(BulkProcessor.java:303) at org.elastic
浏览 4提问于2016-08-23得票数 0
这是我的示例Json数据，来自.json文件，现在我想对elasticsearch执行bulk_insert，这样我就可以在上面执行操作了，..can有人帮我用java代码动态添加这个数据..this
浏览 133提问于2021-04-26得票数 0
我对Java ThreaPoolExecutor很陌生，我编写了一些任务，以便在弹性搜索中索引文档。通过ThreaPoolExecutor执行该任务，并使其工作正常。请在下面找到我的代码 { Map<String,
浏览 2提问于2018-10-10得票数 1
回答已采纳
1回答
(BulkIndexingClient.java:34)connect_1 | at io.confluent.connect.elasticsearch.bulk.BulkProcessor$BulkTask.call(BulkProcessor.ja
浏览 222提问于2018-08-14得票数 0
object mapping [search_data] can't be changed from nested to non-nested\"}]\n\tat io.confluent.connect.elasticsearch.bulk.BulkProcessor$BulkTask.handleMalformedDoc(BulkProcessor.java:479)\n\tat io.confluent.connect.elasticsearch.bulk.BulkProcessor</e
浏览 4提问于2020-06-02得票数 2
回答已采纳
我使用Elasticsearch Java api的BulkProcessor来插入/更新/删除索引中的文档。以下方法适用于插入和删除操作bulkProcessor.add假设在elasticsearch索引中，我有一个文档 "_id": "abcdefghijk",
"id&
浏览 4提问于2016-08-21得票数 1
elasticsearch 7文档- 在elastisearch7中，HightLevelRest客户端不能与批量处理器一起使用。这与他们在elasticsearch 6- 中的建议不同
有人能提一下他们在elasticsearch 7中使用的是哪个客户端和批量处理器吗？
浏览 59提问于2019-08-01得票数 3
回答已采纳
这就是我从elastic.co那里得到的 client, @Override.setFlushInterval(TimeValue.timeValueSeconds(5))
浏览 3提问于2015-05-06得票数 0
回答已采纳
-01:9300,elasticsearch-master-02:9300,elasticsearch-master-03:9300"
String[] strs = { "This", "is", "a", "goodjsonBuilder.field(String.
浏览 1提问于2016-02-12得票数 2
batch 36528 of 1 records after total of 6 attempt(s) (io.confluent.connect.elasticsearch.bulk.BulkProcessor(BulkIndexingClient.java:34) at io
浏览 10提问于2018-01-08得票数 0
回答已采纳
1回答
包装弹力搜索的异步批量索引
、、、、
其想法是在Elasticsearch中提供一个反应性Spring微服务来批量索引文档。Elasticsearch提供了一个高级Rest客户端，它提供了一个异步方法来批量处理索引请求。(10); // Submitting 5,000 index requestsbulkListenerToSink(FluxSink<String> sink) {
r
浏览 2提问于2020-04-01得票数 1
回答已采纳
:165) at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:149)
at
浏览 46提问于2014-01-09得票数 16
回答已采纳
我是Elasticsearch的新手。我知道有两种方法可以进行批量操作：
RestHighLevelClient client = initESclient();
logger.infodata:"+(en
浏览 6提问于2017-11-08得票数 0
我跟随在Flink应用程序中创建一个Elasticsearch接收器。
浏览 4提问于2020-09-15得票数 0
回答已采纳
我能够从Python API获得滚动ID：query = {"query":{"match_all":{
浏览 9提问于2014-10-15得票数 12
1回答
我试图使用Kafka消息(作为StreamSource)更新Elasticsearch中的文档。使用windows和Elasticsearch连接器作为接收器在大容量中写入Elasticsearch是很好的，但是，我们需要更新文档中的现有数据并以大容量的方式读取它(不是针对每个元组，而是针对我们希望聚合的
浏览 1提问于2019-05-28得票数 1
回答已采纳
我使用[java] kafka-producer将数据推送到kafka-topic x，使用[java] high level consumer/bulkProcessor从主题x读取数据，并使用索引数据将数据推送到elasticsearch。当我在运行producer之后第一次启动bulkProcessor的java代码时，我只看到9条记录被推送到ES中，全部都是使用"_version": 1的。第十项记录不在ES中。Going to execute new bulk composed of 10 actio
浏览 2提问于2016-06-06得票数 0
回答已采纳
" % "elasticsearch" % "5.5.1", "org.apache.flinkscala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.NoSuchMethodErr
浏览 0提问于2017-08-08得票数 1
我使用bulkProcessor在ElasticSearch中插入/更新大容量。ElasticBulkProcessorListener listener = new ElasticBulkProcessorListener(updateOperations); .setBulkActions(MAX_BULK_ACTIONS)s
浏览 10提问于2017-03-01得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号