Interface Datum

Input datum for session reduce operations. Contains message data, keys, timestamps, and headers.

interface Datum {
    eventTime: Date;
    headers: Record<string, 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.

keys: string[]

Set of keys in the (key, value) terminology of map/reduce paradigm. Messages are grouped by these keys within a session.

value: Buffer

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

watermark: Date

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