createOrReplaceTempView не является членом org.apache.spark.rdd.RDD

Question

Я использую hadoop 2.7.2, hbase 1.4.9, spark 2.2.0, scala 2.11.8 и java 1.8 . Я запускаю эту команду без каких-либо ошибок:

val Patterns_fromHbase = mimic_PatternsFromHbase.mapPartitions(f=> f.map(row1 => (Bytes.toString(row1._2.getRow), Bytes.toString(row1._2.getValue(Bytes.toBytes("sepsiscategories"),Bytes.toBytes("subject_id")))))).toDF("id","subject_id")

Затем я запускаю эту команду:

mimic_PatternsFromHbase.createOrReplaceTempView("subject_id_table")

, и у меня просто появляется эта ошибка:

:57: ошибка: значение createOrReplaceTempView не является членом org.apache.spark.rdd.RDD [(org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result)] mimic_PatterneplaceRate("subject_id_table")

что является причиной этой ошибки и как ее исправить пожалуйста

Answer 1

Я нашел свою вину, это вина плохого внимания. в месте вызова метода createOrReplaceView, вызвав их Patterns_fromHbase Я назвал ее mimic_PatternsFromHbase