pyflink.table.expressions.timestamp_diff

timestamp_diff(time_point_unit: TimePointUnit, time_point1, time_point2) → Expression

Returns the (signed) number of TimePointUnit between time_point1 and time_point2.

For example, timestamp_diff(TimePointUnit.DAY, lit(“2016-06-15”).to_date, lit(“2016-06-18”).to_date leads to 3.

Parameters:

• time_point_unit – The unit to compute diff.

• time_point1 – The first point in time.

• time_point2 – The second point in time.

Returns:

The number of intervals as integer value.

Added in version 1.12.0.