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失败后,它会非常执着的再来一遍。

  • 相关阅读:
    中文字体
    URL锚点HTML定位技术机制
    关于JS异步加载方案
    select标签用法
    javascript refresh page 几种页面刷新的方法
    用JavaScript刷新框架子页面的七种方法
    robots.txt用法
    netstat 基本用法
    linux下ps命令
    socket编程和并发服务器
  • 原文地址:https://www.cnblogs.com/zlslch/p/6784958.html
Copyright © 2011-2022 走看看