Interface Datum

Input datum for accumulator operations. Contains message data, keys, timestamps, and metadata.

interface Datum {
    eventTime: Date;
    headers: Record<string, string>;
    id: string;
    keys: string[];
    value: Buffer;
    watermark: Date;
}

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.

id: string

Unique identifier for the message. Used for deduplication.

keys: string[]

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

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.