码迷,mamicode.com
首页 > Web开发 > 详细

flume学习(四)---channel

时间:2018-02-07 22:44:18      阅读:501      评论:0      收藏:0      [点我收藏+]

标签:单元测试   uid   说明   nbsp   memory   channels   冲突   custom   否则   

  定义:Channels are the repositories where the events are staged on a agent. Source adds the events and Sink removes it.

  本文根据flume官网提供的Flume 1.8.0 User Guide整理得出的,主要内容是总结了flume1.8.0支持的各种schannel,见下表。

channel类型 type 存储介质 说明    
Memory Channel memory  内存 events被存储在内存中    
JDBC Channel jdbc  数据库 events被持久化至数据库    
Kafka Channel org.apache.flume.channel.kafka.KafkaChannel  Kafka cluster  The events are stored in a Kafka cluster     
File Channel file  本地磁盘某个文件  如果没有配置文件路径,则采用默认路径。但是如果有两个或两个以上File channel,则需要你至少指定一个文件路径,否则会发生冲突。    
Spillable Memory Channel(实验性) SPILLABLEMEMORY an in-memory queue and on disk 优先存储数据至内存,当内存溢出后存储在磁盘    
Pseudo Transaction Channel org.apache.flume.channel.PseudoTxnMemoryChannel   只能用于单元测试    
Custom Channel 自定义FQCN        

flume学习(四)---channel

标签:单元测试   uid   说明   nbsp   memory   channels   冲突   custom   否则   

原文地址:https://www.cnblogs.com/walkingzq/p/8428331.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!