pyspark.sql.functions.count_distinct¶
-
pyspark.sql.functions.
count_distinct
(col: ColumnOrName, *cols: ColumnOrName) → pyspark.sql.column.Column[source]¶ Returns a new
Column
for distinct count ofcol
orcols
.New in version 3.2.0.
Examples
>>> df.agg(count_distinct(df.age, df.name).alias('c')).collect() [Row(c=2)]
>>> df.agg(count_distinct("age", "name").alias('c')).collect() [Row(c=2)]