我有一个JSON消息进入partition record
处理器,在该处理器中,我基于在日期列partition_dt
上。现在,我需要根据其他一些列(例如:/text:equals('XXX')
)来过滤该分区中的一些记录。有没有一种方法可以在同一partitionrecord
中的partition column
处理器中添加多个列?分组记录的条件语句?
我该如何处理?
这将是一个两步过程,先过滤然后分区,或者先分区然后过滤。
您可以使用QueryRecord编写用于过滤的SQL select语句。