Flume NG有4个主要的组件:
Event表示在Flume各个Agent之间传递的数据流
Source表示从外部源接收Event数据流,然后传递给Channel
Channel表示对从Source传递的Event数据流的临时存储
Sink表示从Channel中接收存储的Event数据流,并传递给下游的Source或者终点仓库
这篇看一下Event接口表示的数据流。Source, ...
分类:
Web程序 时间:
2015-06-16 16:52:55
阅读次数:
178
1.flume是分布式的日志收集系统,把收集来的数据传送到目的地去。
2.flume里面有个核心概念,叫做agent。agent是一个java进程,运行在日志收集节点。
3.agent里面包含3个核心组件:source、channel、sink。
3.1 source组件是专用于收集日志的,可以处理各种类型各种格式的日志数据,包括avro、thrift、exec、jms、spooling d...
分类:
Web程序 时间:
2015-06-16 14:45:05
阅读次数:
188
1. Flume:日志收集软件,里面的重要概念是agent,包括 source -> channel -> slink,sourc,slink 可以为hdfs,jdbc ... 一个简单的场景是用Flume监测一个文件夹fdir的数据变化,这时fdir就是source,并将变化传送到hdfs_pat...
分类:
其他好文 时间:
2015-06-10 15:27:14
阅读次数:
141
Component InterfaceType AliasImplementation Classorg.apache.flume.Channelmemoryorg.apache.flume.channel.MemoryChannelorg.apache.flume.Channeljdbcorg.a...
分类:
Web程序 时间:
2015-06-08 16:41:40
阅读次数:
243
项目中使用log4j打印的内容同时传输到flume1、flume端flume的agent配置内容如下:12345678910111213141516a1.sources=s1a1.sinks=k1a1.channels=c1 a1.sources.s1.channels=c1a1.sinks.k1....
分类:
移动开发 时间:
2015-06-08 16:40:25
阅读次数:
214
Flume SourceSource类型说明Avro Source支持Avro协议(实际上是Avro RPC),内置支持Thrift Source支持Thrift协议,内置支持Exec Source基于Unix的command在标准输出上生产数据JMS Source从JMS系统(消息、主题)中读取数...
分类:
Web程序 时间:
2015-06-08 16:37:39
阅读次数:
270
Flume Source 实例Avro Source监听avro端口,接收外部avro客户端数据流。跟前面的agent的Avro Sink可以组成多层拓扑结构。12345678910111213141516a1.sources=s1a1.sinks=k1a1.channels=c1 a1.sourc...
分类:
Web程序 时间:
2015-06-08 16:29:30
阅读次数:
161
Flume 基于Channel Selector可以实现扇入、扇出。同一个数据源分发到不同的目的,如下图。 在source上可以定义channel selector:123456789a1.sources=r1...a1.channels=c1 c2...a1.sources.r1.selector...
分类:
Web程序 时间:
2015-06-08 16:28:59
阅读次数:
123
Is Flume a good fit for your problem?If you need to ingest textual log data into Hadoop/HDFS then Flume is the right fit for your problem, full stop. ...
分类:
Web程序 时间:
2015-06-08 16:27:09
阅读次数:
194
Flume的一些组件(如Spooling Directory Source、File Channel)能够保证agent挂掉后不丢失数据。1、负载均衡1)LoadbalancingSinkProcessorsource里的event流经channel,进入sink组,在sink组内部根据负载算法(r...
分类:
Web程序 时间:
2015-06-07 18:52:57
阅读次数:
348