Class Record

    • Field Detail

      • NO_DATA

        protected static final byte[] NO_DATA
      • watermark

        protected long watermark
      • data

        @Nullable
        protected byte[] data
      • flagsAsByte

        protected byte flagsAsByte
      • traceContext

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

        @Nullable
        protected String appenderThread
    • Constructor Detail

      • 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