Javaのファイルで使用したいRecordService APIのScala Implicitクラスがあります。JavaでScala暗黙のクラスを使用する方法
package object spark {
implicit class RecordServiceContext(ctx: SparkContext) {
def recordServiceTextFile(path: String) : RDD[String] = {
new RecordServiceRDD(ctx).setPath(path)
.map(v => v(0).asInstanceOf[Text].toString)
}
}
}
今私は、インポートの下に使用してJavaファイルでこれをインポートしようとしています。
import com.cloudera.recordservice.spark.*;
しかし、私はsparkContextからrecordServiceTextFile( "パス")を使用することはできませんよ。
Scalaではインポートが少し異なり、動作します。
:このようなものになるだろう
。 –
JavaコードでのScalaコードの読み込みは、私の目にとっては簡単な操作ではありません。 javacの内部構造をある程度理解する必要があります。また、質問は明確ではありません。あなたは質問にもっとはっきりすることができますか?より多くの "完全な"質問は、より良い答え。 –
@Rameshあなたは歓迎ですが、それは私ではありませんでした。 –