?????? ??????????????????pyflink??udaf??????????????????????????????????????????????????????????????????????????Vectorized Aggregate Functions??????case????????????????????????????case?? ??????????????????????"org.apache.flink.table.api.ValidationException: Undefined function: weighted_avg" ??????????????????????pyflink??udaf??????????????????????????????????
