createProcessingTimeWatermark()

Builds a processing-time watermark helper for more aggressive stream progress.

Signature

function createProcessingTimeWatermark<T>(
  options?: {
    now?: () => bigint
    floorToEventTime?: boolean
  },
): WatermarkFunction<T>