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_PatternsFromHbase.createOrReplaceTempView（“ subject_id_table”）

请引起此错误的原因及解决方法

Answer 1

我发现了我的错，这是疏忽大意的错。在通过Patterns_fromHbase调用createOrReplaceView方法的地方，我通过mimic_PatternsFromHbase

调用了她