code: protected InputStream getCompressorInputStream(InputStream inputStream,
  			CompressionType compressionType) throws IOException {
  		switch (compressionType) {
  		case NONE:
  			return inputStream;
  		case GZIP:
  			return new GZIPInputStream(inputStream);
  		case BZ2:
  			return new BZip2CompressorInputStream(new BufferedInputStream(
  					inputStream));
  		default:
  			throw new IllegalArgumentException("Unsupported compression type: "
  					+ compressionType);
  		}
  	}
docs: Returns an input stream that applies the required decompression to the
  given input stream.
  
  @param inputStream
  the input stream with the (possibly compressed) data
  @param compressionType
  the kind of compression
  @return an input stream with decompressed data
  @throws IOException
  if there was a problem creating the decompression streams