NiFi:用于分组的ParitionRecord处理器

问题描述 投票:0回答:1

我有一个JSON消息进入partition record处理器,在该处理器中,我基于在日期列partition_dt上。现在,我需要根据其他一些列(例如:/text:equals('XXX'))来过滤该分区中的一些记录。有没有一种方法可以在同一partitionrecord中的partition column处理器中添加多个列?分组记录的条件语句?

enter image description here

我该如何处理?

apache-nifi
1个回答
0
投票

这将是一个两步过程,先过滤然后分区,或者先分区然后过滤。

您可以使用QueryRecord编写用于过滤的SQL select语句。

© www.soinside.com 2019 - 2024. All rights reserved.