Real-time 节点
Real-time 节点提供一个实时索引。通过这些节点索引的数据提供查询。real-time节点将定期将他们收集的数据转移到同一跨域时间的Historical节点。 使用zookeeper监控传输和MySQL存储的元数据转移。一旦转移,转移的部分从real-time节点中删除。
运行类
io.druid.cli.Main server realtime
Segment传播过程
Firehose
See Firehose.
Plumber
See Plumber
Extending the code
Realtime integration is intended to be extended in two ways:
- Connect to data streams from varied systems (Firehose)
- Adjust the publishing strategy to match your needs (Plumber)
The expectations are that the former will be very common and something that users of Druid will do on a fairly regular basis. Most users will probably never have to deal with the latter form of customization. Indeed, we hope that all potential use cases can be packaged up as part of Druid proper without requiring proprietary customization.
Given those expectations, adding a firehose is straightforward and completely encapsulated inside of the interface. Adding a plumber is more involved and requires understanding of how the system works to get right, it’s not impossible, but it’s not intended that individuals new to Druid will be able to do it immediately.
最新文章
- MS SQL Server 数据库分离-SQL语句
- Windows内存小结
- jQuery动态产生的铵钮怎样实现事件处理
- Scala 深入浅出实战经典 第79讲：单例深入讲解及单例背后的链式表达式
- sql server 2008还原数据库，出现缺少介质问题
- DataTable转换List<T>集合的方法
- 【转】MongoDB资料汇总专题
- JavaScript--循环--打印星星和99乘法表
- RH033读书笔记(2)-Lab 3 Getting Help with Commands
- C#面向对象复习概要
- Process Monitor V2.96 (系统监视工具) 汉化免费绿色版
- Arduino线程库ProtoThreads
- Big big world
- 【干货】Chrome插件(扩展)开发全攻略
- .Net语言 APP开发平台——Smobiler学习日志：如何设置页面的title
- OkHttpHelper使用
- elasticsearch聚合操作——本质就是针对搜索后的结果使用桶bucket（允许嵌套）进行group by，统计下分组结果，包括min/max/avg
- Practical Lessons from Predicting Clicks on Ads at Facebook
- 158A Next Round
- Unity3D 入门 游戏开发 Unity3D portal game development