??
class PercentileUDAF extends AggregateFunction[String, ListBuffer[Float]]{
//
val percentile1 = 0.5
val percentile2 = 0.75
val percentile3 = 0.98
val percentile4 = 0.99
override def getValue(accumulator: ListBuffer[Float]): String = {
//
val
??
??
bigdata
?? 2021-01-18 14:52
user-zh
?? flink sql hopudafmerge??
??
flink1.10.1
sql??hop??udaf??merge
??
flink1.10.1
sql??hop??udaf??merge??merge??
org.apache.flink.table.planner.codegen.CodeGenException: No matching merge
method found for AggregateFunction com.autoai.cns.udaf.PercentileUDAF'
merge ??
??
flink1.10.1
sql??hop??udaf??merge??merge??
org.apache.flink.table.planner.codegen.CodeGenException: No matching merge
method found for AggregateFunction com.autoai.cns.udaf.PercentileUDAF'
merge ??
??
flink1.10.1
sql??hop??udaf??merge??merge??
org.apache.flink.table.planner.codegen.CodeGenException: No matching merge
method found for AggregateFunction com.autoai.cns.udaf.PercentileUDAF'
def merge(accumulator:
merge??marge
Evan Cheng
2021??1??18??09:00:07
bigdata
?? 2021-01-17 22:31
user-zh
?? flink sql hopudaf
??
flink1.10.1sql
hop??udaf
??
flink1.10.1sql
hop??udafmarge??
org.apache.flink.table.api.ValidationException: Function class
'com.autoai.cns.udaf.PercentileUDAF' does not implement at least one method
named 'merge' which is public, not abstract and (in case of table
??
flink1.10.1sql
hop??udafmarge??
org.apache.flink.table.api.ValidationException: Function class
'com.autoai.cns.udaf.PercentileUDAF' does not implement at least one method
named 'merge' which is public, not abstract and (in case of table
