flume Morphiline拦截器:用于数据清理

c0vxltue  于 2021-06-04  发布在  Flume
关注(0)|答案(1)|浏览(555)

我有一个简单的结构化输入来实时。但它的值中也有垃圾,比如在某些地方有“@”或十六进制字符。
如何使用Morphiline flume拦截器清除数据?
我这里的Flume是hbase。

uubf1zoe

uubf1zoe1#

听起来你可以在Flume上使用morphline来满足你的需求。一般来说,morphline提供了一些解析和转换数据的基本函数。除此之外,还可以构建自己的morphline命令,然后在morphline配置中使用自定义方法。

相关问题