- 链接地址：https://blog.csdn.net/clearlxj/article/details/118788096
- 链接标题：Flume-自定义Source_flume自定义source_魔笛Love的博客-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：7138
自定义Source将通过for循环的方式在造数据，并定义两个配置项，一个是有默认值，一个没有默认值，分别的对配置项进行测试。测试时的Flume为：自定义source+logger sink。Java代码如下：public class MySource extends AbstractSource implements Configurable, PollableSource { // 定义全局的前缀和后缀 private String prefix; private Stri_flume自定义source
版权声明：本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除
