Spark Column Aggregates

I’m reading through the source code, and see that MetaSparkDFDataset does not have a column_aggregate_expectation classmethod. Can we not use column aggregates/have to implement our own for spark datasets?

1 Like

The method column_map_expectation is implemented in MetaSparkDFDataset's parent class - MetaDataset.

If you want to implement a new column aggregate expectation for Spark, decorate your method with

@MetaSparkDFDataset.column_aggregate_expectation

1 Like