如何將選項[RDD]轉換爲RDD

Question

我正在使用以下某個鍵將RDD存儲到可變的哈希表中。

var datasets = new HashMap[String, RDD[T]]() 
val feedRdd: RDD[T] = ... 
datasets.put("someKey", feedRdd) 

現在我試圖獲取從HashMap中的相同RDD和它返回選項[RDD [T]下面

val feedRddNew = datasets.get("someKey") 

而且它給錯誤這樣的事情。

類型選項中的表達[RDD [T]]沒有確認到預期類型 RDD [T]

基本上我想存儲到RDD的Hashmap這樣我可以從哈希映射取它因爲我需要。對此有何想法？請讓我知道是否有問題或其他方式。 謝謝！

Answer 1

val feedRddNew = datasets.get("someKey") 

該getter返回一個選項[T]其中T是存儲在地圖中的類型。

所以，要麼無，或一些（T）

，所以你可以做

val theActualValue = feedRddNew.get 

或者，你可以只使用

datasets("someKey") 

其犯規返回一個選項（它拋出如果沒有找到密鑰）