使用ElasticSearch JDBC River从表中获取更改
我正在为ElasticSearch配置JDBC河，但找不到任何好的配置示例。我已经阅读了Elasticsearch-river-
jdbc
GitHub上的所有页面。
我有一个SQL查询，我需要每X秒从所有表列中获取更改。我如何告诉JDBC river某些行已更改并应重新索引？
在ES服务器启动期间获取数据，正在进行轮询，但是没有从DB到ES获取更改。
我的配置：
curl -XPUT 'localhost:9200/_river/itemsi/_meta' -d '{
"type" : "jdbc",
"jdbc" : {
"driver" : "com.mysql.jdbc.Driver",
"url" : "jdbc:mysql://mydb.com:3306/dbname",
"user" : "yyy",
"password" : "xxx",
"sql" : "SELECT ii.id AS _id, ii.id AS myid, ... FROM ... LEFT JOIN .. ON...",
"poll" : "6s",
"strategy" : "simple"
},
"index" : {
"index" : "invoiceitems",
"bulk_size" : 600,
"max_bulk_requests" : 10,
"bulk_timeout" : "5s",
}
}'
谢谢。
问题答案：
加
“自动提交”：true
在索引设置中。然后问题就解决了
-
我正在使用Room从表中加载数据，并在android应用程序中显示它。 然而，该表中的行数很大，所以我不能使用LiveData在表更改时自动触发并更新我的回收器视图 我目前正在做的是，当在我的应用程序中的某个点进行更改（插入-删除-更新）时，存储库会保留所有更改的列表，当我移回显示这些更改的屏幕时，viewmodel会将行ID与加载的行ID进行比较，并根据需要更新ui。 有更好的方法吗？例如，使用
-
问题内容： 我正在尝试使用Java中的metastore客户端从配置单元metastore中获取表属性，表db，名称，所有者和hdfs位置。我想我可以获取表数据库和名称，但是我不知道如何获取所有者和hdfs位置之类的东西。可能吗？我一直在搜索文档和互联网两个小时，而且没有骰子。 问题答案： 可能是这样的： https://hive.apache.org/javadocs/r1.2.2/api/or
-
我正在尝试使用Rest Asure获取的第一个值，用于。 当我使用 我得到： 学生ID 123有10多个课程列表。也可以使用正则表达式从JSON响应中获取特定元素，或者当我有几千行JSON响应时，如何获取元素的路径。 样本响应-
-
如何以简单简洁的方式从列表中获取随机项<如果我想从这个列表中得到一个偶数随机数，那么。 注意： 我知道java中有一些类似的答案可以解决这个问题，但我认为我们可以在kotlin中有一个更简洁的方法。
-
问题内容： K，所以我有两个表： 我想从类别中获取所有信息，并计算每个类别中的问题数（question_id）。 假设，第一个类别（计费）将有一个问题，第二个类别（安全）将有3个问题。 我已经试过了： 问题答案： 您想这样做： 在将确保没有问题类别获得与数= 0上市
-
本文向大家介绍使用ABAP，通过从数据库表获取数据来更改itab中的值，包括了使用ABAP，通过从数据库表获取数据来更改itab中的值的使用技巧和注意事项，需要的朋友参考一下 您应该使用Modify语句执行此操作，如下所示- 还要注意，当您拥有带有标题行的内部表itab时，这意味着您具有表itab和结构itab，并且其用法取决于情况。像MODIFY和LOOP AT这样的命令很少同时使用。 另外，请