title: The output of the Wordcount is being stored in different files
body: <p>The output of the WordCount is being stored in multiple files.
  However the developer doesn't have control on where(ip,path) the files stay on cluster.
  In MapReduce API, there is a provision for developers to write reduce program to address this.How to handle this in ApacheBeam with DirectRunner or any other runners?</p>