腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
解决
这个
错误
值
toDS
不是
org.apache.spark.rdd.RDD
的
成员
?
、
、
我写了这段代码来发送来自推特
的
流数据到elasticsearch,我添加了所有必要
的
依赖项,但我
的
两个函数
toDS
和toES有问题,请帮助我
解决
这个
问题这是我
的
代码:` `package org.lansrod.visualisationSparkSession.builder.config(rdd.sparkContext.getConf).getOrCreate() val caseClassDS = rdd
浏览 25
提问于2020-08-07
得票数 0
3
回答
值
toDS
不是
org.apache.spark.rdd.RDD
的
成员
、
、
、
、
但是在
这个
过程中,我得到了编译时
错误
。下面是我
的
示例代码和
错误
:import org.apache.spark.SparkConfimport org.apache.spark.SparkContextval peopleRDD: RDD[Person] = sc.parallelize(Seq(Person("John", 27))) val people = peopleRDD.
toDS</
浏览 4
提问于2017-06-16
得票数 7
回答已采纳
1
回答
为什么火花RDD
的
行为会因内容不同而有所不同?
、
、
基于,我编写了
这个
非常短
的
测试代码,它可以工作。father", "May the spark be with you", "Spark I am your father") import o
浏览 6
提问于2022-06-16
得票数 1
回答已采纳
2
回答
scala型错配渗透
、
、
我试着让
这个
例子从开始工作。我正在使用Scala2.10和Spark2.0.2。"value
toDS
不是
scala.collection.mutable.ArrayBufferNothing可能
的
原因:也许在‘v
浏览 4
提问于2016-12-08
得票数 1
回答已采纳
1
回答
星星之火:
值
直方图
不是
org.apache.spark.rdd.RDD
[Option[Any]]
的
成员
、
、
、
我刚开始使用spark和scala,我对scala提出了一个编译
错误
:假设我们有一个rdd,它是这样
的
一个映射: //some opssomeInt_var1 //Int "C" -> somelong_var //Long} 然后,我想得到这些vars
的
直方图信
浏览 1
提问于2017-09-10
得票数 1
回答已采纳
1
回答
如何
解决
错误
:
值
reduceByKey
不是
org.apache.spark.rdd.RDD
[(Int,Int)]
的
成员
?
、
、
、
、
1).toInt)); 除最后一个命令外,所有命令都已成功执行,该命令引发以下
错误
:我找到了一些
解决
办法,比如: 这来自于一般性地使用一对reduceByKey方法实际上是PairRDDFunctions类
的
一种方法,它有来自RDD.
浏览 2
提问于2017-12-04
得票数 0
1
回答
将星火RDD转换为dataset
、
、
、
在某些文本挖掘之后,我试图进行一次k均值聚类,但是我找不到
如何
在ParseWikipedia.termDocumentMatrix方法所需
的
数据集中转换kmean.fit
的
结果此外,还测试了提供
的
线索:<console>:69: error:
浏览 3
提问于2018-01-05
得票数 1
回答已采纳
1
回答
scala中
的
第二组RDD
、
、
、
、
我试图在我
的
函数中将两个RDDs合组,以便进行一些计算。我
的
代码如下: (nameKey.toUpperCase(), s) }
值
协
浏览 2
提问于2015-06-04
得票数 0
回答已采纳
1
回答
火花leftOuterJoin问题- leftOuterJoin
不是
org.apache.spark.rdd.RDD
的
成员
[(字符串,字符串)]
、
我正在尝试为leftOuterJoin编写一个简单
的
包装器。我一开始就这样遇到了奇怪
的
问题,import org.apache.spark.SparkContext._ (self.leftOuterJoin(other)) }
错误
:
值</
浏览 1
提问于2015-09-07
得票数 0
1
回答
sortBy
不是
org.apache.spark.rdd.RDD
的
成员
、
、
、
、
val data = sc.parallelize(Array(Array(1,2,3), Array(2,3,4), Array(1,2,1))
错误
值
sortBy
不是
org.apache.spark.rdd.RDD
(Int,Int) data.map(x => (x(d),1)).reduceByKey((x,y) => x+
浏览 0
提问于2016-10-25
得票数 1
回答已采纳
1
回答
错误
:
值
toDF
不是
org.apache.spark.rdd.RDD
[Category]
的
成员
、
我在将rdd转换成DF()时出错: value toDF
不是
org.apache.spark.rdd.RDDCategory
的
成员
,有人能帮我
解决
这个
问题吗?
浏览 3
提问于2015-12-28
得票数 0
0
回答
错误
:
值
简洁
不是
org.apache.spark.rdd.RDD
[String]
的
成员
、
、
以下是我根据文档所做
的
尝试:val data = sc.textFile("file:///home/aman/data/jsonDoc1我得到
的
错误
如下所示 <console>:32: error: value succinct is not a member of
org.apache.spark.rdd.RDD
[String]val succintdata =
浏览 1
提问于2016-07-08
得票数 2
1
回答
Databricks ApacheSpark1.4:不可序列化
的
任务(Scala)
、
、
我在databricks中创建了两个不同
的
Scala笔记本。一个是在LDA模型
的
基础上计算主题,另一个是新
的
笔记本,没有任何事先
的
计算。当我在第一本笔记本上运行以下代码时:val c: Int = 4我得到“任务不可串行化”
错误
。当我在另
浏览 1
提问于2015-07-03
得票数 1
回答已采纳
1
回答
错误
:
值
联接
不是
org.apache.spark.rdd.RDD
[(Long,U)]
的
成员
?
、
(idx, row) } | }<console>:52: error: value join is not a member of
org.apache.spark.rdd.RDD
[(Long, U)] val
浏览 0
提问于2016-01-23
得票数 1
回答已采纳
4
回答
如何
解除RDD?
、
我使用cache()来缓存内存中
的
数据,但是我意识到,在没有缓存数据
的
情况下,我需要对其进行缓存,以从内存中删除数据://doing some computation但我得到
的
错误
是:
值
uncache
不是
org.apache.spark.rdd.RDD
[(Int,ArrayFloat)]
的
成员
。
浏览 3
提问于2014-09-19
得票数 32
回答已采纳
2
回答
值
联接
不是
org.apache.spark.rdd.RDD
的
成员
、
我得到了
这个
错误
:
org.apache.spark.rdd.RDD
[(Long, (Int, (Long, String, Array[_0])))我找到
的
唯一建议是import org.apache.spark.SparkContext编辑:更改代码以消除forSome (即,当对象
的
类型为
org.apache.spar
浏览 1
提问于2015-03-26
得票数 4
回答已采纳
1
回答
Scala代码在火花终端上工作,但在eclipse中不起作用。
、
、
当我在火花终端上运行它时,下面的代码工作得很好,但是在eclipse中,它会抛出一个
错误
。可能是什么原因。如果你需要更多
的
信息,请告诉我。._1 ))
值
mapValues
不是
org.apache.spark.rdd.RDD
[(Int,Iterable(String,Int))]
的
成员
代码在shell上运行得非常好
浏览 1
提问于2014-07-08
得票数 0
回答已采纳
1
回答
Scala -
如何
解决
“
值
不是
空
的
成员
”
错误
、
、
这个
示例代码是基于Atmosphere类
的
,但如果有人能给我一些关于
错误
的
一般含义
的
见解,我想我可以找出任何特定于Atmosphere
的
解决
方案……bc.broadcast(message) 在第一行之后,bc应该包含一个对象
的
句柄,该对象
的
类定义包含broadcast()方法--实际上,它包含几个重载<
浏览 0
提问于2013-08-02
得票数 5
回答已采纳
1
回答
createOrReplaceTempView
不是
org.apache.spark.rdd.RDD
的
成员
、
、
、
、
我使用
的
是Hadoop2.7.2、HBASE1.4.9、SPAC2.2.0、Scala2.11.8和Java1.8。我在没有任何
错误
的
情况下运行此命令:然后运行以下命令: mimic_PatternsFromHbase.createOrReplaceTempView("subje
浏览 3
提问于2019-11-05
得票数 0
回答已采纳
1
回答
在中
的
Scala
、
、
最后一个字段应转换为布尔
值
.。[15] at filter at <console>:28 :25:
错误
:
值
toDouble
不是
org.apache.spark.sql.Row
的
成员
有人
浏览 1
提问于2021-01-27
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
在UG编程的过程中,新手玩家会出现如下错误时,这个要如何解决呢
瑞风协同“十年磨一剑” 国内试验信息化首个国家标准出台
易语言编程常见错误
Kotlin与Java 如何解决 Null 问题?
2017年最全的excel函数大全11—多维数据集函数
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券