Class NoopCompressor

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

    public class NoopCompressor
    extends VeniceCompressor
    • Constructor Detail

      • NoopCompressor

        public NoopCompressor()
    • Method Detail

      • compress

        public byte[] compress​(byte[] data)
                        throws java.io.IOException
        Specified by:
        compress in class VeniceCompressor
        Throws:
        java.io.IOException
      • compress

        public java.nio.ByteBuffer compress​(java.nio.ByteBuffer data,
                                            int startPositionOfOutput)
                                     throws java.io.IOException
        Specified by:
        compress in class VeniceCompressor
        Throws:
        java.io.IOException
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • decompress

        public java.nio.ByteBuffer decompress​(java.nio.ByteBuffer data)
                                       throws java.io.IOException
        Specified by:
        decompress in class VeniceCompressor
        Throws:
        java.io.IOException
      • decompress

        public java.nio.ByteBuffer decompress​(byte[] data,
                                              int offset,
                                              int length)
                                       throws java.io.IOException
        Specified by:
        decompress in class VeniceCompressor
        Throws:
        java.io.IOException
      • decompressAndPrependSchemaHeader

        public java.nio.ByteBuffer decompressAndPrependSchemaHeader​(byte[] data,
                                                                    int offset,
                                                                    int length,
                                                                    int schemaHeader)
                                                             throws java.io.IOException
        Description copied from class: VeniceCompressor
        This method tries to decompress data and maybe prepend the schema header. The returned ByteBuffer will be backed by byte array that starts with schema header, followed by the decompressed data. The ByteBuffer will be positioned at the beginning of the decompressed data and the remaining of the ByteBuffer will be the length of the decompressed data.
        Specified by:
        decompressAndPrependSchemaHeader in class VeniceCompressor
        Throws:
        java.io.IOException
      • decompress

        public java.io.InputStream decompress​(java.io.InputStream inputStream)
                                       throws java.io.IOException
        Specified by:
        decompress in class VeniceCompressor
        Throws:
        java.io.IOException
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object