Skip to content

Commit

Permalink
bump htsjdk dependency version to 0.20.3
Browse files Browse the repository at this point in the history
  • Loading branch information
heuermh committed Sep 11, 2019
1 parent 9f974cf commit 9cd7d67
Show file tree
Hide file tree
Showing 6 changed files with 13 additions and 8 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@

<properties>
<java.version>1.8</java.version>
<htsjdk.version>2.14.2</htsjdk.version>
<htsjdk.version>2.20.3</htsjdk.version>
<!-- CHANGE THIS FOR A DIFFERENT VERSION OF HADOOP -->
<hadoop.version>2.9.0</hadoop.version>
<!--
Expand Down
5 changes: 3 additions & 2 deletions src/main/java/org/seqdoop/hadoop_bam/BAMRecordWriter.java
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
package org.seqdoop.hadoop_bam;

import htsjdk.samtools.util.BlockCompressedStreamConstants;
import java.io.File;
import java.io.IOException;
import java.io.OutputStream;
import java.io.StringWriter;
Expand Down Expand Up @@ -109,11 +110,11 @@ private void init(
origOutput = output;

if (useIntelDeflater) {
compressedOut = new BlockCompressedOutputStream(origOutput, null,
compressedOut = new BlockCompressedOutputStream(origOutput, (File) null,
BlockCompressedStreamConstants.DEFAULT_COMPRESSION_LEVEL,
IntelGKLAccessor.newDeflaterFactory());
} else {
compressedOut = new BlockCompressedOutputStream(origOutput, null);
compressedOut = new BlockCompressedOutputStream(origOutput, (File) null);
}

binaryCodec = new BinaryCodec(compressedOut);
Expand Down
3 changes: 2 additions & 1 deletion src/main/java/org/seqdoop/hadoop_bam/BCFRecordWriter.java
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

package org.seqdoop.hadoop_bam;

import java.io.File;
import java.io.FilterOutputStream;
import java.io.IOException;
import java.io.OutputStream;
Expand Down Expand Up @@ -166,7 +167,7 @@ final class BCFStoppableOutputStream extends FilterOutputStream {
private final OutputStream origOut;

public BCFStoppableOutputStream(boolean startStopped, OutputStream out) {
super(new BlockCompressedOutputStream(out, null));
super(new BlockCompressedOutputStream(out, (File) null));
origOut = out;
stopped = startStopped;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package org.seqdoop.hadoop_bam.util;

import htsjdk.samtools.util.BlockCompressedOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.OutputStream;
import org.apache.hadoop.io.compress.CompressionOutputStream;
Expand All @@ -20,7 +21,7 @@ class BGZFCompressionOutputStream extends CompressionOutputStream {
public BGZFCompressionOutputStream(OutputStream out)
throws IOException {
super(out);
this.output = new BlockCompressedOutputStream(out, null);
this.output = new BlockCompressedOutputStream(out, (File) null);
}

public void write(int b) throws IOException {
Expand All @@ -37,7 +38,7 @@ public void finish() throws IOException {

public void resetState() throws IOException {
output.flush();
output = new BlockCompressedOutputStream(out, null);
output = new BlockCompressedOutputStream(out, (File) null);
}

public void close() throws IOException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

package org.seqdoop.hadoop_bam.util;

import java.io.File;
import java.io.FilterOutputStream;
import java.io.IOException;
import java.io.OutputStream;
Expand Down Expand Up @@ -101,7 +102,7 @@ private OutputStream prepareSAMOrBAMStream(
final String text = sw.toString();

if (format == SAMFormat.BAM) {
out = new BlockCompressedOutputStream(out, null);
out = new BlockCompressedOutputStream(out, (File) null);
out.write(BAM_MAGIC);
writeInt32(out, text.length());
}
Expand Down
3 changes: 2 additions & 1 deletion src/main/java/org/seqdoop/hadoop_bam/util/VCFFileMerger.java
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
import htsjdk.variant.variantcontext.writer.VariantContextWriterBuilder;
import htsjdk.variant.vcf.VCFHeader;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
Expand Down Expand Up @@ -95,7 +96,7 @@ private static boolean writeHeader(OutputStream out, Path outputPath, List<Path>
boolean gzipCompressed = isGzipCompressed(parts);
OutputStream headerOut;
if (blockCompressed) {
headerOut = new BlockCompressedOutputStream(out, null);
headerOut = new BlockCompressedOutputStream(out, (File) null);
} else if (gzipCompressed) {
headerOut = new GZIPOutputStream(out);
} else {
Expand Down

0 comments on commit 9cd7d67

Please sign in to comment.