Batch Processing Time¶
Batch Processing Time (aka Batch Timeout Threshold) is the processing time (processing timestamp) of the current streaming batch.
The following standard functions (and their Catalyst expressions) allow accessing the batch processing time in Micro-Batch Stream Processing:
CurrentDate expressions are not supported in Continuous Stream Processing.
FlatMapGroupsWithStateExec physical operator has the processing time undefined and set to the current timestamp in the state preparation rule every streaming batch.
MicroBatchExecutionis requested to construct a next streaming micro-batch in <