zoukankan      html  css  js  c++  java
  • Flume的sink

    Flume的sink

      console[("format")] :直接将将数据显示在consolr上。

      text(“txtfile”):将数据写到文件txtfile中。

      dfs(“dfsfile”):将数据写到HDFS上的dfsfile文件中。

      syslogTcp(“host”,port):将数据通过TCP传递给host节点。

      agentSink[("machine"[,port])]:等价于agentE2ESink,如果省略,machine参数,默认使用 flume.collector.event.host与flume.collector.event.port作为默认collecotr。

      agentDFOSink[("machine" [,port])]:本地热备agent,agent发现collector节点故障后,不断检查collector的存活状态以便重新发送event,在此间产生的数据将缓存到本地磁盘中。

      agentBESink[("machine"[,port])]:不负责的agent,如果collector故障,将不做任何处理,它发送的数据也将被直接丢弃。

      agentE2EChain:指定多个collector提高可用性。 当向主collector发送event失效后,转向第二个collector发送,当所有的collector失败后,它会非常执着的再来一遍。

  • 相关阅读:
    nginx命令
    linux 命令
    js导出excel页面数据
    Linux上使用shell脚本查看内存情况(超实用)
    Gson解析json繁杂数据
    纯js制作遮罩层对话框
    简易树形菜单(可伸缩)
    一句实现jquery导航栏
    沁园春-雪
    python day3 int,str,list类型补充
  • 原文地址:https://www.cnblogs.com/zlslch/p/6784958.html
Copyright © 2011-2022 走看看