@getter<EOL>def aggregate(input, **params):
PARAM_CFG_EXTRACT = '<STR_LIT>'<EOL>PARAM_CFG_SUBSTITUTE = '<STR_LIT>'<EOL>PARAM_CFG_AGGREGATE = '<STR_LIT>'<EOL>AGGR_FIELD = '<STR_LIT>'<EOL>AGGR_FUNC = '<STR_LIT>'<EOL>extract_params = params.get(PARAM_CFG_EXTRACT)<EOL>extract_params.update({AccessParams.KEY_TYPE: AccessParams.TYPE_MULTI})<EOL>dataset = __extract(input, extract_params)<EOL>if PARAM_CFG_SUBSTITUTE in params:<EOL><INDENT>dataset = __substitute(input, dataset, params.get(PARAM_CFG_SUBSTITUTE))<EOL><DEDENT>cfg = params.get(PARAM_CFG_AGGREGATE)<EOL>res = Aggregator.agg_single_func(dataset, cfg[AGGR_FIELD], cfg[AGGR_FUNC])<EOL>return res<EOL>
Returns aggregate
:param input:
:param params:
:return: