Class Message

constructor

• new Message(
      value: Buffer,
      id: string,
      eventTime: Date,
      watermark: Date,
      headers: Record<string, string>,
      options?: accumulator.MessageOptions,
  ): accumulator.Message

  Create a new accumulator output message.

  Parameters

  • value: Buffer

    The message payload

  • id: string

    Unique message ID (usually from input datum)

  • eventTime: Date

    Event time

  • watermark: Date

    Watermark timestamp

  • headers: Record<string, string>

    Message headers

  • Optionaloptions: accumulator.MessageOptions

    Optional keys and tags

  Returns accumulator.Message

eventTime

headers

id

Optionalkeys

Optionaltags

value

watermark

StatictoDrop

• toDrop(): accumulator.Message

  Create a drop message that will be discarded.

  Returns accumulator.Message

  A message marked for dropping