code: @Override
    public CompressionInputStream createInputStream(InputStream in,
        Decompressor decompressor) throws IOException {
      if (!isNativeSnappyLoaded(conf)) {
        throw new RuntimeException("native snappy library not available");
      }
  
      return new BlockDecompressorStream(in, decompressor, conf.getInt(
          IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_KEY,
          IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_DEFAULT));
    }
docs: Create a {@link CompressionInputStream} that will read from the given
  {@link InputStream} with the given {@link Decompressor}.
  
  @param in
  the stream to read compressed bytes from
  @param decompressor
  decompressor to use
  @return a stream to read uncompressed bytes from
  @throws IOException