我有一个按Transaction_ID对所有产品进行分组的数据集，我想排除少于两个产品的Transaction_ID。withColumn("Product_ID", concat_ws(",", col("Product_ID"))).count().filter("count >= 2") <console>:37: error: value filter
浏览 6提问于2016-09-26得票数 0
回答已采纳
1回答
顶点模式是： |-- company: string (nullable = true)...aggregateMessages .agg(myUDFA(AM.msg).as("aggMess"))我得到了一个错误这
浏览 1提问于2018-01-31得票数 2
回答已采纳
我得到了这个错误： org.apache.spark.rdd.RDD[(Long, (Int, (Long, String, Array[_0])))我找到的唯一建议是import org.apache.spark.SparkContext编辑:更改代码以消除forSome (即，当对象的类型为o
浏览 1提问于2015-03-26得票数 4
回答已采纳
1回答
import org.apache.spark.sql.{Dataset, DataFrame, SparkSession}
:37:错误:值排序不是单元df.sort的成员($“年份
浏览 0提问于2018-07-13得票数 0
回答已采纳
我刚开始使用spark和scala，我对scala提出了一个编译错误:假设我们有一个rdd，它是这样的一个映射： //some opsMap( "B" -> someInt_var2 //Int
"C" -> somelong_var //<e
浏览 1提问于2017-09-10得票数 1
回答已采纳
我尝试了所有可能的方法，导入所有可能的库，并查找与saveAstextFile或saveAsSequenceFile相关的所有问题的答案，甚至都没有帮助。因此，启动一个新线程。我得到了一个错误“错误:值saveAsTextFile不是scala.collection.Map[String,Long] countResult.saveAsTextFile("tmp/testfile").的
浏览 4提问于2017-10-11得票数 0
回答已采纳
> def isEqual[U, V](expected: RDD[U], result: RDD[V]) = { | val resultIndexValue: RDD[(Long(idx, row) }
| val combined = expectedIndexValue.join(result
浏览 0提问于2016-01-23得票数 1
回答已采纳
2回答
我无法在Scala程序中执行从RDD到Dataframe的隐式转换，尽管我正在导入spark.implicits._。object spark1 {
val spark = SparkSession.builder().appNameTestDataB.txt")
浏览 6提问于2017-05-31得票数 1
回答已采纳
按照ScalaARM主页上的示例，我编写了以下内容：(打开lucene IndexReader)
错误：(34，45) Play 2 Compiler: Indexer.scala:34: valuefilter不是managed(DirectoryReader.open(FSDirectory.open(fi
浏览 9提问于2015-07-11得票数 0
回答已采纳
我下载了Geotrellis，并尝试按照上的说明进行操作错误: object spark不是包geotrellis import geotrellis.spark._的成员
我以前遇到过以下问题:
浏览 3提问于2019-05-16得票数 0
我正在尝试为leftOuterJoin编写一个简单的包装器。我一开始就这样遇到了奇怪的问题，import org.apache.spark.SparkContext._ (self.leftOuterJoin(other))
}
浏览 1提问于2015-09-07得票数 0
我是指网站链接，以实现二级排序在我的火花工作。import org.apache.spark.SparkContextimport org.apache.spark.SparkConf: String, EventTs: Long) {
implicit def orderingBySerialNum[A <: DeviceKey] : Ordering[A] = {DeviceKey("2&quo
浏览 2提问于2017-03-27得票数 1
回答已采纳
[Array[Int]] = ParallelCollectionRDD[0] at parallelize at <console>:26
错误值sortBy不是org.apache.spark.rdd.RDD(Int，Int) data.map(x => (x(d)，1)).reduceByKey((x，y) => x+.reduceByKey<=的</
浏览 0提问于2016-10-25得票数 1
回答已采纳
如果从vprog函数返回参数元组，则不会发生错误，但如果使用相同的元组返回新元组，则会得到空点错误。--而不是访问元组的成员，则不会发生错误： vertexDTA错误是
[Stage 101:>
浏览 0提问于2018-03-11得票数 0
回答已采纳
1回答
在中的Scala
、、
最后一个字段应转换为布尔值.。is org.apache.spark.rdd.RDD[org.apache.spark.sql.Row] = MapPartitionsRDD[14] at rdd at <console>:23[15] at filter at <console>:28 :25:错误:值
浏览 1提问于2021-01-27得票数 0
我尝试做的是检查第一级是否有.parentSearch属性作为.search属性存在于任何其他对象的.filter数组中。我想，既然我想返回一个修改过的对象，那么减少这个对象并检查内部是很好的。is in any of the value.filtersif(_.find(currentfilters, value.parentSearch)){
浏览 1提问于2016-01-08得票数 0
1回答
我经常看到，当我们使用map函数时，我们可以使用case类从rdd创建一个数据格式，如下所示：row_num:Long,non_matches)class filematches1(
val row_num:Long
浏览 0提问于2018-12-06得票数 1
回答已采纳
我用的是AWS笔记本。我可以运行正常的基于scala的火花作业，而不需要第三方库依赖关系。但是，我想加载一些常见的库，如some、mysql-连接器等。%%configure -f "conf": {
"spark.jars": "s3://bucket-xxx/jars/lib/config-1.3.1mysql:mysql-conne
浏览 0提问于2019-11-10得票数 1
回答已采纳
2回答
我有我的密码：{ float ile = QVariant((*i).value()).toFloat();我变成了这样的错误：
request for member 'key' in 'i.QHash<K,V>
浏览 4提问于2016-01-25得票数 1
回答已采纳
2回答
无法将字符串转换为长整型
、、、、
每当timeConverter的getAsString函数被调用时，我都会在long timeMillis=Long.parseLong(time);行得到数字格式异常，我希望将给定的字符串转换为长整型timeMillis=Long.parseLong(time); long eclapseTime=timeMillis-currentTime;
浏览 0提问于2012-09-28得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
