def _reduce_spark_multi(sdf: SparkDataFrame, aggs: List[Column]) -> Any:
    '\n    Performs a reduction on a spark DataFrame, the functions being known sql aggregate functions.\n    '
    assert isinstance(sdf, SparkDataFrame)
    sdf0 = sdf.agg(*aggs)
    lst = sdf0.limit(2).toPandas()
    assert (len(lst) == 1), (sdf, lst)
    row = lst.iloc[0]
    lst2 = list(row)
    assert (len(lst2) == len(aggs)), (row, lst2)
    return lst2
Performs a reduction on a spark DataFrame, the functions being known sql aggregate functions.
def _reduce_spark_multi(sdf: SparkDataFrame, aggs: List[Column]) -> Any:
    '\n    \n    '
    assert isinstance(sdf, SparkDataFrame)
    sdf0 = sdf.agg(*aggs)
    lst = sdf0.limit(2).toPandas()
    assert (len(lst) == 1), (sdf, lst)
    row = lst.iloc[0]
    lst2 = list(row)
    assert (len(lst2) == len(aggs)), (row, lst2)
    return lst2