pyflink.table.expression.Expression.distinct

property Expression.distinct: Expression

Similar to a SQL distinct aggregation clause such as COUNT(DISTINCT a), declares that an aggregation function is only applied on distinct input values.

Example:

>>> tab \
>>>     .group_by(col("a")) \
>>>     .select(col("a"), col("b").sum.distinct.alias("d"))

Added in version 1.12.0.