</pre><prename="code"class="cpp">classCMainDlg:publicCAxDialogImpl<CMainDlg>,publicCUpdateUI<CMainDlg>,publicCMessageFilter,publicCIdleH...

1、文件滚动策略在HDFSSink的文件滚动就是文件生成，即关闭当前文件，创建新文件。它的滚动策略由以下几个属性控制：hdfs.rollInterval基于时间间隔来进行文件滚动，默认是30，即每隔30秒滚动一个文件。0就是不使用这个策略。hdfs.rollSize基于文件大小进行文件滚动，默认是1024，即当文件大于...

Flume SourceSource类型说明Avro Source支持Avro协议（实际上是Avro RPC），内置支持Thrift Source支持Thrift协议，内置支持Exec Source基于Unix的command在标准输出上生产数据JMS Sou...

Flume的一些组件（如SpoolingDirectorySource、FileChannel）能够保证agent挂掉后不丢失数据。1、负载均衡1）Load balancing Sink Processorsource里的event流经channel，进入sink组，在sink组内部根据负...

Audiosink的设计，需要满足下列一些需求： 良好的chain_based支持。绝大多数简单playbackpipelines都是将音频数据从decoder直接push给audiosink; 良好getrange_based支持。大部分专业的应用都是audiosink从pipeline拉取数据。...