Tôi đã lưu Array[String]
vào tệp Parquet từ Spark.Đọc mảng chuỗi từ Spark
Để đọc nó tôi sử dụng:
row.getAs[Array[String]]("result")
Nhưng nhận được:
java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to [Ljava.lang.String;
Dưới đây là kết quả của printSchema()
:
root
|-- result: array (nullable = true)
| |-- element: string (containsNull = true)
Làm thế nào nên các getAs()
được sửa đổi?
'row.getAs [Seq [String]] (" result ")' có hoạt động không? – Reactormonk
Hoặc 'row.getAs [scala.collection.mutable.WrappedArray [String]] (" kết quả ")'. @ Reactormonk Tôi nghĩ bạn nên làm cho nó một câu trả lời. – zero323
@ zero323 'Seq' và' WrappedArray' hoạt động. Bạn có thấy lý do nào để sử dụng cái này qua cái kia không? Quan tâm hơn đến hiệu suất hơn mức sử dụng. – BAR