2017-07-28 20 views
0

私は以下のようにいくつかのキーを使って可変ハッシュマップにRDDを保存しています。オプション[RDD]をRDDに変換する方法

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

今私はハッシュマップから同じRDDを取得しようとしていますし、それがオプション[RDDを[T]]

val feedRddNew = datasets.get("someKey") 

以下のように戻っていると、それはエラーにこのような何かを与えています。

タイプオプションの発現[RDD [T]]基本的に私はハッシュマップからそれを取り出すことができるようにHashMapにRDD格納したい予想タイプ RDD [T]

に確認しません私が必要としたように。これについての考えは?何かが間違っている場合や代替方法があれば教えてください。 ありがとう!

答えて

1
val feedRddNew = datasets.get("someKey") 

このgetterは、Tがマップに格納されている型であるOption [T]を返します。だから、

、なし、またはいくつかの(T)のいずれか

ので、あなたはただそれだけで(オプションを返すdoes notのどの

datasets("someKey") 

を使用することができます

val theActualValue = feedRddNew.get 

かを行うことができますキーが見つからない場合はスローします)

+1

ありがとうございました。両方とも期待どおりに働いています。 –

関連する問題