zoukankan      html  css  js  c++  java
  • Flume内置channel,source,sink汇总

    由于经常会使用到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.即可!
    收住自己的心 一步一个脚印 做好自己的事
  • 相关阅读:
    java注解说明
    paypal
    eclispe查看jdk源码后特别卡顿导致未响应解决
    ubuntu+tomcat,多环境、自动化部署脚本,git+maven+tomcat+ubuntu
    ubuntu+let's encrypt生成永久免费https证书 ubuntu+tomcat+nginx+let's encrypt
    MySQL创建数据库与创建用户以及授权
    linux查找并杀死进程shell
    redmine安装笔记
    C#动态获取本机可用串口的两种方式
    C# 控件缩写规范
  • 原文地址:https://www.cnblogs.com/GodMode/p/5629359.html
Copyright © 2011-2022 走看看