Funkendatenrahmen Funktionsfehler explodieren

Question

Ich möchte die Funktion auf einem DF explodieren verwenden, schreibe ich nur den Code wie das Dokument:

case class Url(url:String) 
    val temp3 = temp2.explode($"urls"){ 
     case Row(urls:Array[String]) => urls.map(Url(_)) 
    } 

aber es stellte sich heraus:

error: not found: value Row 

die DF TEMP2 ist wie:

temp2.printSchema() 
root 
|-- userid: string (nullable = true) 
|-- urls: array (nullable = true) 
| |-- element: string (containsNull = true) 

Answer 1

die folgenden Import hinzufügen:

import org.apache.spark.sql.Row