@numaproj/numaflow-js - v0.0.0-alpha.4
    Preparing search index...

    Represents an input datum received by the source transform handler.

    Contains all the data and metadata associated with a message from the source.

    Index

    Properties

    eventTime: Date

    Event time of the message as seen at the source

    headers: Record<string, string>

    HTTP-style headers attached to the message

    keys: string[]

    Keys associated with the message for routing and partitioning

    systemMetadata: sourceTransform.SystemMetadata | null

    System-provided metadata, if any

    userMetadata: sourceTransform.UserMetadata | null

    User-defined metadata, if any

    value: Buffer

    The message payload as a Buffer

    watermark: Date

    Watermark timestamp - guarantee that no older messages will arrive