Class ZstdInputStream

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class ZstdInputStream
    extends java.io.FilterInputStream
    InputStream filter that decompresses the data provided by the underlying InputStream using Zstd compression. It does not support mark/reset methods
    • Constructor Detail

      • ZstdInputStream

        public ZstdInputStream​(java.io.InputStream inStream)
                        throws java.io.IOException
        create a new decompressing InputStream
        Parameters:
        inStream - the stream to wrap
        Throws:
        java.io.IOException
      • ZstdInputStream

        public ZstdInputStream​(java.io.InputStream inStream,
                               BufferPool bufferPool)
                        throws java.io.IOException
        create a new decompressing InputStream
        Parameters:
        inStream - the stream to wrap
        bufferPool - the pool to fetch and return buffers
        Throws:
        java.io.IOException
    • Method Detail

      • setFinalize

        @Deprecated
        public void setFinalize​(boolean finalize)
        Deprecated.
        If you don't rely on finalizers, use `ZstdInputStreamNoFinalizer` instead, instances of `ZstdInputStream` will always try to close/release in the finalizer.
        Enable or disable class finalizers
        Parameters:
        finalize - default `true` - finalizers are enabled
      • finalize

        protected void finalize()
                         throws java.lang.Throwable
        Overrides:
        finalize in class java.lang.Object
        Throws:
        java.lang.Throwable
      • recommendedDInSize

        public static long recommendedDInSize()
      • recommendedDOutSize

        public static long recommendedDOutSize()
      • setContinuous

        public ZstdInputStream setContinuous​(boolean b)
        Don't break on unfinished frames Use case: decompressing files that are not yet finished writing and compressing
      • getContinuous

        public boolean getContinuous()
      • setDict

        public ZstdInputStream setDict​(byte[] dict)
                                throws java.io.IOException
        Throws:
        java.io.IOException
      • setLongMax

        public ZstdInputStream setLongMax​(int windowLogMax)
                                   throws java.io.IOException
        Throws:
        java.io.IOException
      • read

        public int read​(byte[] dst,
                        int offset,
                        int len)
                 throws java.io.IOException
        Overrides:
        read in class java.io.FilterInputStream
        Throws:
        java.io.IOException
      • read

        public int read()
                 throws java.io.IOException
        Overrides:
        read in class java.io.FilterInputStream
        Throws:
        java.io.IOException
      • available

        public int available()
                      throws java.io.IOException
        Overrides:
        available in class java.io.FilterInputStream
        Throws:
        java.io.IOException
      • skip

        public long skip​(long numBytes)
                  throws java.io.IOException
        Overrides:
        skip in class java.io.FilterInputStream
        Throws:
        java.io.IOException
      • markSupported

        public boolean markSupported()
        Overrides:
        markSupported in class java.io.FilterInputStream
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Overrides:
        close in class java.io.FilterInputStream
        Throws:
        java.io.IOException