当我有一个单独的函数或一个列表时,我让它可以工作,但是当涉及到聚合变量时,我被困在将它们的列表引入到函数中 def aggregate(dataframe,grouping,aggregation,functions): **First part works ok on single functions and single columns**
df = dataframe.groupby(grouping).min(aggregation<
from("direct:in").routeId("TEST_AGGREGATION_ROUTE") .aggregate(header("THE_ID> size = ${body.size}") // HERE I GET THE AGGREGATION RESULT .log("<OUT> ${body}")