現在、Pcollection を単一の avro ファイルに書き込んでいます。Pcollection を複数のファイルに書きたいと思っています。
PCollection<String> generatedResults = results.parallelDo(new AvroGeneratorDofn(count),Avros.specifics(String.class));
//generatedResults.write(To.avroFile(outputPath));
pipeline.write(generatedResults,new AvroFileTarget(outputPath), Target.WriteMode.APPEND);