API View source
eventTimeWatermark()
Advances stream readiness from event-time timestamps.
Signature
function eventTimeWatermark<T>(
event: EventEnvelope<T>,
): bigint | undefinedAdvances stream readiness from event-time timestamps.
function eventTimeWatermark<T>(
event: EventEnvelope<T>,
): bigint | undefined