create a compressioninputstream that will read from the given inputstream with the given decompressor . concode_field_sep int IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_DEFAULT concode_elem_sep Configuration conf concode_elem_sep String IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_KEY concode_field_sep Configuration getConf concode_elem_sep Decompressor createDecompressor concode_elem_sep boolean isNativeSnappyLoaded concode_elem_sep CompressionOutputStream createOutputStream concode_elem_sep CompressionOutputStream createOutputStream concode_elem_sep Class<? extends Compressor> getCompressorType concode_elem_sep Compressor createCompressor concode_elem_sep Class<? extends Decompressor> getDecompressorType concode_elem_sep void setConf concode_elem_sep String getDefaultExtension
CompressionInputStream function ( InputStream arg0 , Decompressor arg1 ) { if ( ! isNativeSnappyLoaded ( conf ) ) { throw new RuntimeException ( "srini_string" ) ; } return new BlockDecompressorStream ( arg0 , arg1 , conf . getInt ( IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_KEY , IO_COMPRESSION_CODEC_SNAPPY_BUFFERSIZE_DEFAULT ) ) ; }