您有两种选择：
使用Flume拦截器，在这里检查答案。
使用基于流的解决方案（apache spark、apache heron/storm）过滤记录，然后将其存储在hdfs中，
第二个选项使您可以更灵活地编写不同类型的流模式。如果有更多查询，请添加注解。