Flume可以给数据添加头吗？

Question

我正在处理这样的数据。{"a":1,"b":2} 我想让Flume在所有数据中添加一个头，如 {"header":self_define,"content":{"a":1,"b":2}}

我看了一些关于Flume拦截器的资料，但似乎它们只能用来修改水槽的输出路径。有什么方法可以实现这一点，或者我必须自己开发一个拦截器类？

感谢任何帮助。

Answer 1

尝试使用Flume Morphline Interceptor。

Flume MorphlineInterceptor在被拦截的事件上运行形态线的变换。例如，形态线可以忽略事件，或者使用基于正则表达式的模式匹配来改变或插入某些事件头。