dataflow-java
dataflow-java copied to clipboard
Update ShardedBAMWriting to be compatible with parallel BAM reading.
WriteBAMTransform used by ShardedBAMWriting assumes that it receives reads in order.
Add a group by and a sort operation so that input reads can be read from multiple BAM shards in parallel.