SparkSQL 之 基於Java實現UDF和UDAF詳解

UDF 源碼：最多傳入參數爲22個java //傳入兩個參數 def register(name: String, f: UDF2[_, _, _], returnType: DataType): Unit = { val func = f.asInstanceOf[UDF2[Any, Any, Any]].call(_: Any, _: Any) functionRegistry.reg

>>阅读原文<<