pyflink.table.expression.Expression.distinct

property Expression.distinct: pyflink.table.expression.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"))

New in version 1.12.0.