flink 1.9 ??????UDAF ????state??????????????

[star]

??????????


flink 1.9 ??????UDAF ????state??????????????


??????sql???? ????????stage??


class MyFunc extends AggregateFunction{
createAccumulator
accumulate
getValue
merge
  }