Class Record

java.lang.Object
org.nuxeo.lib.stream.computation.Record
All Implemented Interfaces:
Externalizable, Serializable

public class Record extends Object implements Externalizable
Basic data object that contains: key, watermark, flag and data.
Since:
9.3
See Also:
  • Field Details

    • NO_DATA

      protected static final byte[] NO_DATA
    • watermark

      protected long watermark
    • key

      protected String key
    • data

      @Nullable protected byte[] data
    • flags

      protected transient EnumSet<Record.Flag> flags
    • flagsAsByte

      protected byte flagsAsByte
    • traceContext

      @Nullable protected byte[] traceContext
      Since:
      11.1 used for tracing context propagation
    • appenderThread

      @Nullable protected String appenderThread
  • Constructor Details

    • Record

      public Record()
    • Record

      public Record(String key, byte[] data)
      Creates a record using current watermark corresponding to the current time, with a default flag
    • Record

      public Record(String key, byte[] data, long watermark)
      Creates a record using a default flag
    • Record

      public Record(String key, byte[] data, long watermark, EnumSet<Record.Flag> flags)
  • Method Details