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.