由于经常会使用到Flume的一些channel,source,sink，于是为了方便将这些channel,source,sink汇总出来，也共大家访问。
| Component Interface | Type Alias | Implementation Class |
| *.Channel | memory | *.channel.MemoryChannel |
| *.Channel | jdbc | *.channel.jdbc.JdbcChannel |
| *.Channel | file | *.channel.file.FileChannel |
| *.Channel | – | *.channel.PseudoTxnMemoryChannel |
| *.Channel | – | org.example.MyChannel |
| *.Source | avro | *.source.AvroSource |
| *.Source | netcat | *.source.NetcatSource |
| *.Source | seq | *.source.SequenceGeneratorSource |
| *.Source | exec | *.source.ExecSource |
| *.Source | syslogtcp | *.source.SyslogTcpSource |
| *.Source | multiport_syslogtcp | *.source.MultiportSyslogTCPSource |
| *.Source | syslogudp | *.source.SyslogUDPSource |
| *.Source | spooldir | *.source.SpoolDirectorySource |
| *.Source | http | *.source.http.HTTPSource |
| *.Source | thrift | *.source.ThriftSource |
| *.Source | jms | *.source.jms.JMSSource |
| *.Source | – | *.source.avroLegacy.AvroLegacySource |
| *.Source | – | *.source.thriftLegacy.ThriftLegacySource |
| *.Source | – | org.example.MySource |
| *.Sink | null | *.sink.NullSink |
| *.Sink | logger | *.sink.LoggerSink |
| *.Sink | avro | *.sink.AvroSink |
| *.Sink | hdfs | *.sink.hdfs.HDFSEventSink |
| *.Sink | hbase | *.sink.hbase.HBaseSink |
| *.Sink | asynchbase | *.sink.hbase.AsyncHBaseSink |
| *.Sink | elasticsearch | *.sink.elasticsearch.ElasticSearchSink |
| *.Sink | file_roll | *.sink.RollingFileSink |
| *.Sink | irc | *.sink.irc.IRCSink |
| *.Sink | thrift | *.sink.ThriftSink |
| *.Sink | – | org.example.MySink |
| *.ChannelSelector | replicating | *.channel.ReplicatingChannelSelector |
| *.ChannelSelector | multiplexing | *.channel.MultiplexingChannelSelector |
| *.ChannelSelector | – | org.example.MyChannelSelector |
| *.SinkProcessor | default | *.sink.DefaultSinkProcessor |
| *.SinkProcessor | failover | *.sink.FailoverSinkProcessor |
| *.SinkProcessor | load_balance | *.sink.LoadBalancingSinkProcessor |
| *.SinkProcessor | – | |
| *.interceptor.Interceptor | timestamp | *.interceptor.TimestampInterceptor$Builder |
| *.interceptor.Interceptor | host | *.interceptor.HostInterceptor$Builder |
| *.interceptor.Interceptor | static | *.interceptor.StaticInterceptor$Builder |
| *.interceptor.Interceptor | regex_filter | *.interceptor.RegexFilteringInterceptor$Builder |
| *.interceptor.Interceptor | regex_extractor | *.interceptor.RegexFilteringInterceptor$Builder |
| *.channel.file.encryption. KeyProvider$Builder | jceksfile | *.channel.file.encryption.JCEFileKeyProvider |
| *.channel.file.encryption. KeyProvider$Builder | – | org.example.MyKeyProvider |
| *.channel.file.encryption.CipherProvider | aesctrnopadding | *.channel.file.encryption.AESCTRNoPaddingProvider |
| *.channel.file.encryption.CipherProvider | – | org.example.MyCipherProvider |
| *.serialization.EventSerializer$Builder | text | *.serialization.BodyTextEventSerializer$Builder |
| *.serialization.EventSerializer$Builder | avro_event | *.serialization.FlumeEventAvroEventSerializer$Builder |
| *.serialization.EventSerializer$Builder | – | org.example.MyEventSerializer$Builder |
由于表格太大了，所以这里将org.apache.flume.替换为*.，读者在阅读的时候，直接将*.理解成org.apache.flume.即可！
Sinks
| Sources
| Decorators
|
原创文章版权归过往记忆大数据（过往记忆）所有，未经许可不得转载。
本文链接: 【Flume内置channel,source,sink汇总】（https://www.iteblog.com/archives/948.html）
