文件名称:Flume 根据字段进行路由插入 ES
文件大小:31.99MB
文件格式:GZ
更新时间:2022-05-16 10:12:26
Elasti Flume
基于Flume-1.8.0,ES-5.6.11 , 根据某个字段创建 type ,进行路由批量插入 ES,使用redis 缓存已从MySQL 查出的转换数据
【文件预览】:
GEOSink
----src()
--------test()
--------main()
----target()
--------GEOSink-1.0-SNAPSHOT.jar(35.28MB)
--------maven-status()
--------generated-sources()
--------classes()
--------maven-archiver()
--------archive-tmp()
----.idea()
--------misc.xml(513B)
--------compiler.xml(528B)
--------uiDesigner.xml(9KB)
--------workspace.xml(44KB)
----pom.xml(5KB)
----GEOSink.iml(80B)