2016-03-07 69 views
0

類參數傳遞給saveAsSequenceFile()我想如何在斯卡拉

SequenceFileRDDFunctions.saveAsSequenceFile(path: String, codec: Option[Class[_ <: CompressionCodec]] = None) 

我要給「BZip2Codec」作爲第二個參數來調用這個方法在我的斯卡拉程序。不過,我下面嘗試,但它未能編譯:

import org.apache.hadoop.io.compress.BZip2Codec 
.... 
rdd.saveAsSequenceFile(path, Option[BZip2Codec]) 
// missing arguments for method apply in object Option; 
// follow this method with `_' if you want to treat it as a partially applied function 

有人可以請幫助如何通過類「BZip2Codec」作爲第二個參數?非常感謝。

回答

1
rdd.saveAsSequenceFile(path, Some(classOf[BZip2Codec])) 
+0

非常感謝。這解決了我的問題。 – jlp