Trident中的过滤与函数的区别

时间:2023-03-09 01:52:11
Trident中的过滤与函数的区别

1.共同点

  都需要实现storm.trident.operation.Function接口

2.不同点

  其中函数有发射这个步骤。

    .each(new Fields("orderTime"),new DateTransFormerFunction(),new Fields("day","hour","minter"))

    其中DateTransFormerFunction中有这样的程序:tridentCollector.emit(new Values(day,hour,minute))

  过滤只是返回isKepp中的状态,true或者false