注意:以下问题的答案中给出的建议不适用于value toDF is not a member of org.apache.spark.rdd.RDD value toDF is not a memberof org.apache.spark.rdd.RDD[Weather] 我正在尝试编写一个泛型函数，它只为给定数据集中的每个键保留前k个值： 代码如下： def topKReduceByKey[K:.reverse)
浏览 17提问于2019-09-19得票数 0
我附加了错误"value toDF不是org.apache.spark.rdd.RDD的成员“的代码片段。我使用的是scala 2.11.8和spark 2.0.0。您能帮我解决toDF()接口的这个问题吗？val HData = hospitalData.map(_.split(",")).map(toService(_))
val hosService=HData.toDF<
浏览 20提问于2017-03-11得票数 3
._ sc.stop()我已经写了为什么在这种情况下是不正确的？我见过许多其他方法将rdd转换为数据帧，但我的大部分代码都是用toDF()编写的。怎样才能让toDF正常工作？错误：
Error:(25, 55) value toDF is not a
浏览 0提问于2016-07-05得票数 4
._name := "PickACustomer"
import scala.collection.mutable.Map
import org.apache.spark.rdd.RDDnflips
浏览 3提问于2016-03-17得票数 4
回答已采纳
people = sc.textFile("resources/people.txt").map(_.split(",")).map(p => Person(p(0), p(1).trim.toInt)).toDF()下面是TestApp.scala文件：impo
浏览 9提问于2015-11-14得票数 30
在这里，我想使用toDF方法将RDD转换为DataFrame，但我无法识别错误。,p(7),p(8),p(9),p(10))) | val hosService = hData.toDF") | }错误：
<console>:61: error: value toDFis not a membe
浏览 0提问于2018-05-10得票数 0
这段代码在火花壳中是正常的，但在Intellj中是异常的.import org.apache.spark.p(11).trim.toDouble, p(13).trim.toDouble,
浏览 0提问于2018-09-10得票数 0
回答已采纳
我在将rdd转换成DF()时出错: value toDF不是org.apache.spark.rdd.RDDCategory的成员，有人能帮我解决这个问题吗？
浏览 3提问于2015-12-28得票数 0
我得到了这个错误： org.apache.spark.rdd.RDD[(Long, (Int, (Long, String, Array[_0])))我找到的唯一建议是import org.apache.spark.SparkContext编辑:更改代码以消除forSome (即，当对象的类型为org.apache.spark.rdd.RDD[(Lo
浏览 1提问于2015-03-26得票数 4
回答已采纳
我想在一个DataFrames中合并来自不同DataFrames的两列val ds1 = sc.parallelize(Seq(1,0,1,0)).toDF("Col1")ds1.show()
| Col1||+-----+
+-----++-----
浏览 0提问于2019-11-13得票数 0
回答已采纳
clazz.getDeclaredConstructors()(0)val df = rddtoinsert.map { }.map(payload => { // instance of dynamic class当我执行它时会说：
va
浏览 4提问于2018-01-28得票数 3
._
rdd: org.apache.spark.rdd.RDD= [_1: map<int,int>, _2: int]
rdd: org.apache.spark.rdd.RDD<console>:30: error: value
浏览 0提问于2015-09-11得票数 7
回答已采纳
我想声明一个函数来得到两个cogroup的RDD。实际上它是interSectionByKey。下面的代码无法编译： }
浏览 3提问于2015-11-17得票数 0
回答已采纳
1回答
首先，我有一个类型为(Int，Int)的RDD，名为dataPair。然后，我使用以下命令创建了一个带有列标题的DataFrame对象：然后，我使用以下命令将其从DataFrame转换回RDD：它返回org.apache.spark.sql.Row类型的RDD (不是(整数，整数))。然后我想用.toDF把它转换回RDD，但是
浏览 1提问于2016-05-04得票数 11
回答已采纳
1回答
我正在尝试使用Scala中的sparkStreaming来捕获Kafka事件(我正在以序列化的形式获取它)。下面是我的代码片段： )
messages.foreachR
浏览 0提问于2018-10-24得票数 0
",4),("d",12)))
val d = b.map{case(k,v) => (k) -> (Non
浏览 2提问于2017-11-23得票数 0
1回答
值subtractByKey不是subtractByKeyLabeledPoint的成员
org.apache.spark.rdd.RDD(String，LabeledPoint)是对值RDD，我已经导入了import org.apache.spark.rdd._。
浏览 4提问于2015-06-09得票数 0
.rdd .toDF()下面是完整的代码：
import java.io
浏览 0提问于2016-10-04得票数 3
我的具体问题是，如果我们可以将RDD hospitalDataText转换为DataFrame(使用.toDF())，hospitalDataText使用Spark (而不是sqlContext.read.csv我的主要目的是使用header .show() 函数查看变量 RDD的数据，因此为什么不能将RDD转换为DataFrame？请检查下面给出的代码！hospitalDataText: org.apache.spark.rdd.RDD[String] = /
浏览 2提问于2017-08-19得票数 1
回答已采纳
为什么在这种情况下是不正确的？我见过许多其他方法将rdd转换为数据帧，但我的大部分代码都是用toDF()编写的。怎样才能让toDF正常工作？ratings = ratings_raw.map(x => x.split("::")).map(r => Rating(r(0).toInt, r(1).toInt, r(2).toFloat)).toDF
浏览 41提问于2019-01-31得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
