Как я могу сделать то же самое в java, что и в Scala 'classOf [List [String]]'?

Question

Вот демо для Спарк чтения Protobuf в Скале: SparkReadProtoBuf.scala

Я не знаю, как я могу сделать то же самое в Java, как и в Scala: classOf[BinaryWritable[MyProtocolBuffers.MyProtocolBuffer]]

И я использую следующий код Java не имеет никакого эффекта :

JavaPairRDD<LongWritable, ProtobufWritable> rdd = sc.newAPIHadoopFile(
      path, 
      MultiInputFormat.class, 
      LongWritable.class, 
      ProtobufWritable.class, 
      conf); 

Большое спасибо.

Answer 1

Вы должны использовать

BinaryWritable.class вместо ProtobufWritable.class

эта ссылка может оказаться полезным

How to do MyClass<String>.class in Java?