Module proctime_udf 

Processing-time UDF for PROCTIME() support Processing-time UDF for DataFusion integration

Provides a proctime() scalar function that returns the current wall-clock timestamp. Used to declare processing-time watermarks:

CREATE SOURCE events (
    data VARCHAR,
    ts TIMESTAMP,
    WATERMARK FOR ts AS PROCTIME()
);

Structs

ProcTimeUdf

Scalar UDF that returns the current processing time.