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

    Interface Datum

    Input datum received by the map handler. Contains the message data, keys, timestamps, and optional metadata.

    interface Datum {
        eventTime: Date;
        headers: Record<string, string>;
        keys: string[];
        systemMetadata: map.SystemMetadata | null;
        userMetadata: map.UserMetadata | null;
        value: Buffer;
        watermark: Date;
    }
    Index

    Properties

    eventTime headers keys systemMetadata userMetadata value watermark

    Properties

    eventTime: Date

    Time of the element as seen at source or aligned after a reduce operation.

    headers: Record<string, string>

    HTTP-style headers attached to the message.

    keys: string[]

    Set of keys in the (key, value) terminology of map/reduce paradigm. Used for routing and partitioning messages.

    systemMetadata: map.SystemMetadata | null

    System-provided metadata, if any.

    userMetadata: map.UserMetadata | null

    User-defined metadata, if any was attached to this message.

    value: Buffer

    The message payload as a Buffer. Contains the actual data to be processed.

    watermark: Date

    Watermark timestamp. A guarantee that no messages older than this time will arrive.

    Settings

    Member Visibility

    On This Page

    Properties