diff --git a/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java b/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java index c076ea6e8def..9ee57459f564 100644 --- a/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java +++ b/java-util/src/main/java/io/druid/java/util/common/CompressionUtils.java @@ -318,8 +318,10 @@ public static FileUtils.FileCopyResult gunzip(InputStream in, File outFile) thro * @param in The raw input stream * * @return A GZIPInputStream that can handle concatenated gzip streams in the input + * + * @see #decompress(InputStream, String) which should be used instead for streams coming from files */ - private static GZIPInputStream gzipInputStream(final InputStream in) throws IOException + public static GZIPInputStream gzipInputStream(final InputStream in) throws IOException { return new GZIPInputStream( new FilterInputStream(in)