오버로드 방법 값 UDF는

Question

나는 다음과 같은 코드를 사용하여 Databricks 커뮤니티 에디션에서 테이블을 등록하려고 :

overloaded method value udf with alternatives:

Answer 1

귀하의 UDF 구문 외모 : 그러나

import org.apache.spark.sql.functions.udf 

val getDataUDF(url: String):Unit = udf(getData(url: String):Unit) 

을, 오류가 발생합니다 조금 이상하다. getData()을 호출 할 때 타입을 정의하면 안된다. 추가로, UDF에 대한 입력은 메소드 자체 내에 있어야합니다.

는 예를 들어, 다음과 같은 방법 getData이 (가 리턴 값을 가져야한다) :

1. 재 작성 :

   def getData(url: String): String = {...} 
   

   는 UDF로하려면 두 가지 방법이 있습니다 getData 함수로서

   val getData: (String => String) = {...} 
   val getDataUDF = udf(getData) 
   

2. 를 호출UDF를

   val getDataUDF = udf((url: String) => { 
       getData(url) 
   }) 
   

다음과 같은 방법으로 모두 개인적으로 나는 방법 (1)가 조금 더 생겼다고 생각 작동합니다 내부 7,373,방법.