Class BaseSerializingTranscoder

    • Field Detail

      • DEFAULT_COMPRESSION_THRESHOLD

        public static final int DEFAULT_COMPRESSION_THRESHOLD
        Default compression threshold value.
        See Also:
        Constant Field Values
      • compressionThreshold

        protected int compressionThreshold
      • charset

        protected java.lang.String charset
      • log

        protected static final org.slf4j.Logger log
      • COMPRESS_RATIO

        static int COMPRESS_RATIO
    • Constructor Detail

      • BaseSerializingTranscoder

        public BaseSerializingTranscoder()
    • Method Detail

      • setCompressionThreshold

        public void setCompressionThreshold​(int to)
        Set the compression threshold to the given number of bytes. This transcoder will attempt to compress any data being stored that's larger than this.
        Parameters:
        to - the number of bytes
      • setCompressionMode

        public void setCompressionMode​(CompressionMode compressMode)
      • setCharset

        public void setCharset​(java.lang.String to)
        Set the character set for string value transcoding (defaults to UTF-8).
      • serialize

        protected byte[] serialize​(java.lang.Object o)
        Get the bytes representing the given serialized object.
      • deserialize

        protected java.lang.Object deserialize​(byte[] in)
        Get the object represented by the given serialized bytes.
      • compress

        public final byte[] compress​(byte[] in)
        Compress the given array of bytes.
      • zipCompress

        private byte[] zipCompress​(byte[] in)
      • gzipCompress

        private static byte[] gzipCompress​(byte[] in)
      • decompress

        protected byte[] decompress​(byte[] in)
        Decompress the given array of bytes.
        Returns:
        null if the bytes cannot be decompressed
      • zipDecompress

        private byte[] zipDecompress​(byte[] in)
      • gzipDecompress

        private byte[] gzipDecompress​(byte[] in)
      • decodeString

        protected java.lang.String decodeString​(byte[] data)
        Decode the string with the current character set.
      • encodeString

        protected byte[] encodeString​(java.lang.String in)
        Encode a string into the current character set.