

def aggregate(self, stream, group_by=None, operators=None):
    "\n        takes an input stream (pandas data frame) and perform a group-by + aggregation.\n        for instance: aggregate(data, group_by=['col1'], operators={'col2': 'sum'})\n        "
    if self._execution_plan:
        self._execution_plan.append('aggregate', 'transform')
    if (group_by and stream):
        return stream.groupby(group_by).agg(operators)
    else:
        return None

dataset/ETHPy150Open Convertro/Hydro/src/hydro/transformers.py Transformers.aggregate/VarMisuse@45/126 `operators`->`stream`