createOrReplaceTempView 不是 org.apache.spark.rdd.RDD 的成员
createOrReplaceTempView is not a member of org.apache.spark.rdd.RDD
我正在使用 hadoop 2.7.2、hbase 1.4.9、spark 2.2.0、scala 2.11.8 和 java1.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: error: value createOrReplaceTempView is not a member of
org.apache.spark.rdd.RDD[(org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result)]
mimic_PatternsFromHbase.createOrReplaceTempView("subject_id_table")
这个错误的原因是什么以及如何解决
我找到了我的错，是注意力不集中的错。
在通过 Patterns_fromHbase 调用 createOrReplaceView 方法的地方 我通过 mimic_PatternsFromHbase
调用了她
我正在使用 hadoop 2.7.2、hbase 1.4.9、spark 2.2.0、scala 2.11.8 和 java1.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: error: value createOrReplaceTempView is not a member of org.apache.spark.rdd.RDD[(org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result)] mimic_PatternsFromHbase.createOrReplaceTempView("subject_id_table")
这个错误的原因是什么以及如何解决
我找到了我的错，是注意力不集中的错。 在通过 Patterns_fromHbase 调用 createOrReplaceView 方法的地方 我通过 mimic_PatternsFromHbase
调用了她