createOrReplaceTempView不是org.apache.spark.rdd.RDD的成员

我正在使用 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”)

此错误的原因是什么以及如何解决该问题

zyz1225 回答:createOrReplaceTempView不是org.apache.spark.rdd.RDD的成员

我发现我的错,这是疏忽大意的错。 在通过 Patterns_fromHbase 进行调用的地方调用createOrReplaceView方法,而通过 mimic_PatternsFromHbase

进行了调用
本文链接:https://www.f2er.com/3157569.html

大家都在问