我有一个简单的结构化输入来实时。但它的值中也有垃圾,比如在某些地方有“@”或十六进制字符。如何使用Morphiline flume拦截器清除数据?我这里的Flume是hbase。
uubf1zoe1#
听起来你可以在Flume上使用morphline来满足你的需求。一般来说,morphline提供了一些解析和转换数据的基本函数。除此之外,还可以构建自己的morphline命令,然后在morphline配置中使用自定义方法。
1条答案
按热度按时间uubf1zoe1#
听起来你可以在Flume上使用morphline来满足你的需求。一般来说,morphline提供了一些解析和转换数据的基本函数。除此之外,还可以构建自己的morphline命令,然后在morphline配置中使用自定义方法。