google-cloud-data-fusion - 如何计算 CDAP/DATA Fusion 中的行数？

Question

如何计算行数，例如我使用NullFieldSplitter插件将数据分成两部分，我想计算每一部分的行数。如何计算它？有人可以看看并帮助我，谢谢。

Answer 1

您可以使用“分析”部分下的“分组依据”插件计算记录数。拆分记录后，您可以将它们传递给 Group By 以使用 Count 聚合方法计算每个端口的记录数。