我试图在减少部分输出一些特定的记录,这取决于键值记录的值。在hadoopmapreduce中可以使用类似的代码publicvoidsetup(Contextcontext)throwsIOException,InterruptedException{super.setup(context);Configurationconf=context.getConfiguration();FileSystemfs=FileSystem.get(conf);inttaskID=context.getTaskAttemptID().getTaskID().getId();hdfsOutWriter=