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:错误:value createOrReplaceTempView不是的成员org.apache.spark.rdd.rdd[(org.apache.hdoop.hbase.io.ImmutableBytesWritable,org.apache.hoop.hbase.client.Result(]mimic_PatternsFromHbase.createOrReplaceTempView("subject_id_table"(

这个错误的原因是什么以及如何修复它,请

我发现了我的错,这是注意力不集中的错。在调用createOrReplaceView方法的地方,通过Patterns_fromHbase调用它们我通过mimic_PatternsFromHbase调用了她

最新更新