原文:flume1.8 Sinks类型介绍(三)

. Flume Sinks . HDFS Sink 该sink把events写进Hadoop分布式文件系统 HDFS 。它目前支持创建文本和序列文件。它支持在两种文件类型压缩。文件可以基于数据的经过时间或者大小或者事件的数量周期性地滚动。它还通过属性 如时间戳或发生事件的机器 把数据划分为桶或区。 agent a 的示例: 上述配置会将时间戳降到最后 分钟。例如,带有 : : AM,June , ...

2018-01-01 23:59 0 4695 推荐指数:

查看详情

flume1.8 Sources类型介绍(二)

1 Flume Sources 1.1 Avro Source 监听Avro端口,从Avro client streams接收events。要求属性是粗体字。 agent a1例子: ipFilterRules例子: ipFilterRules=allow:ip:127. ...

Wed Jan 10 08:18:00 CST 2018 0 5488
flume1.8 Channel类型介绍(四)

1. Flume Channel Channels是events在agent上进行的存储库。Source添加events,Sink移除events。 1.1 Memory Channel(内存Channels) events存储在配置最大大小的内存队列中。对于流量较高和由于agent故障 ...

Thu Jan 04 09:13:00 CST 2018 0 5570
flume1.8 基础架构介绍(一)

1. 系统要求 1. Java运行环境 —— Java 1.8及以上 2. 内存 —— 足够的内存供配置的sources,channels 或者sinks使用 3. 硬盘空间 —— 足够的硬盘空间供配置的channels或者sinks使用 4. 文件权限 —— agent使用的文件夹读写 ...

Sun Dec 31 09:22:00 CST 2017 0 3089
flume1.8 开发指南学习感悟

概述: Apache Flume是一个分布式、可用的系统,用于从许多不同的sources有效的收集并移动大量日志数据用于集中存储数据。 架构及数据流动模型: flume实际上就是一个Agent。Agent里面包含三大组件:Source、Channel、Sink。 Flume agent流动 ...

Sun Dec 24 08:43:00 CST 2017 0 1816
Flume 入门--几种不同的Sinks

主要介绍几种常见Flume的Sink--汇聚点 1.Logger Sink 记录INFO级别的日志,一般用于调试。前面介绍Source时候用到的Sink都是这个类型的Sink 必须配置的属性: 属性说明: !channel ...

Wed Jan 11 05:33:00 CST 2017 1 7366
Flume的各种类型的组件介绍

1. Source NetCat Source:绑定的端口(tcp、udp),将流经端口的每一个文本行数据作为Event输入; type:source的类型,必须是netcat。 bind:要监听的(本机的)主机名或者ip。此监听不是过滤发送方。一台电脑不是说只有一个IP。有多网卡的电脑 ...

Sun Oct 08 01:03:00 CST 2017 0 2331
flume安装及配置介绍(二)

注: 环境: skylin-linux Flume的下载方式:   下载完成之后,使用tar进行解压 进入flume的conf配置包中,使用命令touch flume.conf,然后cp flume ...

Wed Jul 13 22:58:00 CST 2016 0 5253
flume介绍与原理(一)

1 .背景 flume是由cloudera软件公司产出的可分布式日志收集系统,后与2009年被捐赠了apache软件基金会,为hadoop相关组件之一。尤其近几年随着flume的不断被完善以及升级版本的逐一推出,特别是flume-ng;同时flume内部的各种组件不断丰富,用户 ...

Mon Jul 11 03:24:00 CST 2016 1 45595
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM