Как передать параметр класса в saveAsSequenceFile() в Скале

Question

Я пытаюсь вызвать этот метод в моей программе лестницы

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» в качестве второго параметра? Огромное спасибо.

Answer 1

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