An Event is a unit of data that flows through a Flume agent. The Event flows from Source to Channel to Sink, and is represented by an implementation of the Event interface. An Event carries a payload (byte array) that is accompanied by an optional set of headers (string attributes). A Flume agent is a process (JVM) that hosts the components that allow Events to flow from an external source to a external destination.

Source consumes Events having a specific format, and those Events are delivered to the Source by an external source like a web server. For example, an AvroSource can be used to receive Avro Events from clients or from other Flume agents in the flow. When a Source receives an Event, it stores it into one or more Channels. The Channel is a passive store that holds the Event until that Event is consumed by a Sink. One type of Channel available in Flume is the FileChannel which uses the local filesystem as its backing store. A Sink is responsible for removing an Event from the Channel and putting it into an external repository like HDFS (in the case of an HDFSEventSink) or forwarding it to the Source at the next hop of the flow. The Source and Sink within the given agent run asynchronously with the Events staged in theChannel.
 

最新文章

  1. 前端MVVM框架avalon揭秘 - HTML编译器
  2. nodejs中stream相关资料
  3. Windows Store App JavaScript 开发:模板绑定
  4. servlet&jsp高级:第五部分
  5. DOJO 八 event dojo/on
  6. php入门变量之变量的间接引用、连接字符串和连接赋值运算符
  7. JAXB - Annotations, The Object Factory: XmlRegistry, XmlElementDecl
  8. Python中的redis学习笔记
  9. Android Studio apk 打包流程
  10. php判断多维数组的技巧
  11. pycharm python模版样式
  12. servlet的web-xml配置详解
  13. Git----GitHub上传本地文件到git
  14. C#类型(一)
  15. Spark:将DataFrame写入Mysql
  16. ****** 四十二 ******、软设笔记【网络基础】-IPv6协议、常用的网络协议
  17. Winfrom Chart实现数据统计
  18. Golang 中使用多维 map
  19. linux 常用操作以及概念
  20. mysql 获取一段时间的数据

热门文章

  1. 搭建svn管理平台
  2. angularJs路由的使用
  3. HTML 培训教程
  4. POJ_2478 Farey Sequence 【欧拉函数+简单递推】
  5. 【AC自动机】【树状数组】【dfs序】洛谷 P2414 [NOI2011]阿狸的打字机 题解
  6. 【贪心】洛谷 P1199 三国游戏 题解
  7. C#工具类之XmlNode扩展类
  8. 使用Junit进行自动单元测试
  9. Python学习 day06
  10. nginx 服务器配置文件指令