基于大数据的Flume接收端数据处理方法和装置
基本信息
| 申请号 | CN201610309692.7 | 申请日 | - |
| 公开（公告）号 | CN106648722B | 公开（公告）日 | 2020-01-10 |
| 申请公布号 | CN106648722B | 申请公布日 | 2020-01-10 |
| 分类号 | G06F9/445;H04L29/12 | 分类 | 计算；推算；计数; |
| 发明人 | 宋泰然;王界兵;张伟;施莹;董迪马;梁猛 | 申请（专利权）人 | 深圳前海信息技术有限公司 |
| 代理机构 | 深圳市明日今典知识产权代理事务所（普通合伙） | 代理人 | 深圳前海信息技术有限公司 |
| 地址 | 518000 广东省深圳市前海深港合作区前湾一路鲤鱼门街一号前海深港合作区管理局综合办公楼A栋201室（入驻深圳市前海商务秘书有限公司） | ||
| 法律状态 | - | ||
摘要
| 摘要 | 本发明揭示了一种基于大数据的Flume接收端数据处理方法和装置，其中方法包括：获取Event，根据Event header中的信息对Event排序；通过指定的函数查找对应的Source‑body；如果有对应的Source‑body，则直接标记，如果没有，则使用默认的Source‑body，并动态加载Source‑body，形成一个新的Source‑body；选择对应的Source‑body后，对应生成一个队列，新的Event数据会添加到其队列中；当对应的Source‑body类被选中后，Source‑body以其数据类型选择对应的channel，并与之建立联系。本发明提高数据处理的灵活性。 |
