我在scaldinggroupAll文档中读到:/***Groupalltuplesdowntoonereducer.*(duetocascadinglimitation).*ThisisprobablyonlyusefuljustbeforesettingatailsuchasDatabase*tail,sothatonlyonereducertalkstotheDB.Kindofahack.*/defgroupAll:Pipe=groupAll{_.pass}这让我有充分的理由相信，如果我pipe我的最终write结果到一个statusUpdater管道，它只更新我的一些数据库作业