Class NonCompressor

  • All Implemented Interfaces:
    ValueCompressor

    public class NonCompressor
    extends java.lang.Object
    implements ValueCompressor
    A compressor that doesn't actually compress. It does, however, only emit values when they've changed at all. Flush will return the last emitted value.
    • Method Detail

      • putValue

        public java.util.List<QualifiedValue> putValue​(QualifiedValue value)
        Description copied from interface: ValueCompressor
        Places a value into the compressor to be processed. Any available processed values are returned. Will return an empty list if no values should be emitted (will not return null).

        Important: For performance reasons, the list returned may be the same object between calls. Therefore, it should not be held onto. The values should be utilized directly after calling this function.

        Specified by:
        putValue in interface ValueCompressor
      • flush

        public java.util.List<QualifiedValue> flush()
        Description copied from interface: ValueCompressor
        Tells the compressor to return any values it can. Can be used before shutdown, or when the max-age has been reached in order to force values to be written.

        Important: For performance reasons, the list returned may be the same object between calls. Therefore, it should not be held onto. The values should be utilized directly after calling this function.

        Specified by:
        flush in interface ValueCompressor