Class SnappyCodec


  • public class SnappyCodec
    extends java.lang.Object
    Preamble header for SnappyOutputStream.

    The magic header is the following 8 bytes data:

     -126, 'S', 'N', 'A', 'P', 'P', 'Y', 0
     

    • Field Detail

      • MAGIC_HEADER

        static final byte[] MAGIC_HEADER
      • MAGIC_LEN

        public static final int MAGIC_LEN
      • HEADER_SIZE

        public static final int HEADER_SIZE
      • MAGIC_HEADER_HEAD

        public static final int MAGIC_HEADER_HEAD
      • MINIMUM_COMPATIBLE_VERSION

        public static final int MINIMUM_COMPATIBLE_VERSION
        See Also:
        Constant Field Values
      • currentHeader

        public static final SnappyCodec currentHeader
      • magic

        public final byte[] magic
      • version

        public final int version
      • compatibleVersion

        public final int compatibleVersion
      • headerArray

        private final byte[] headerArray
    • Constructor Detail

      • SnappyCodec

        private SnappyCodec​(byte[] magic,
                            int version,
                            int compatibleVersion)
    • Method Detail

      • getMagicHeader

        public static byte[] getMagicHeader()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • headerSize

        public static int headerSize()
      • writeHeader

        public int writeHeader​(byte[] dst,
                               int dstOffset)
      • writeHeader

        public int writeHeader​(java.io.OutputStream out)
                        throws java.io.IOException
        Throws:
        java.io.IOException
      • isValidMagicHeader

        public boolean isValidMagicHeader()
      • hasMagicHeaderPrefix

        public static boolean hasMagicHeaderPrefix​(byte[] b)
      • readHeader

        public static SnappyCodec readHeader​(java.io.InputStream in)
                                      throws java.io.IOException
        Throws:
        java.io.IOException