scala 相关问题

Scala是一种通用编程语言,主要针对Java虚拟机。旨在以简洁,优雅和类型安全的方式表达通用编程模式,它融合了命令式和函数式编程风格。其主要特点是:具有类型推断的高级静态类型系统;功能类型;模式匹配;隐含参数和转换;运算符重载;与Java的完全互操作性;并发

如何在Spark中转置数据框?

我有以下数据框:+ -------------------- + --- + --- + ----- + ---- + --- ----- + ---- + | AK | 1 | 2 | 3 | 4 | 5 | 6 | + -------------------- + --- + --- + ----- + ---- + -------- + ---- + ......

回答 2 投票 0

计算Spark DataFrame中的非空值的数量

我有一些带有一些列的数据框,在做分析之前,我想了解这样的数据帧是如何完整的,所以我想过滤数据帧并计算每列非数...

回答 3 投票 5

Scala / Spark:如何将此参数传递给.select语句

我有办法得到一个有效的数据框的子集:这工作val subset_cols = {joinCols:+ col} val df1_subset = df1.select(subset_cols.head,subset_cols.tail:_ *)这不起作用:(。 ..

回答 1 投票 -3

在代理后面运行SBT

我试图在企业代理后面运行SBT示例。 sbt new sbt / scala-seed.g8我按照说明设置代理:export SBT_OPTS =“$ SBT_OPTS -Dhttp.proxyHost = myusername:mypassword @ correcthost ...

回答 2 投票 0

数据帧字符串到Hive表Bigint - 如何转换

Spark:1.6,Scala,Hive我有一个数据帧DF.printschema root | - rundatetime:string(nullable = true)| - day_cunt:String(nullable = true)| - my_key:integer(nullable = true)DF。节目() ...

回答 1 投票 0

scala中的隐式json转换器在运行时为null

使用了play框架我有一个case类的文件(在Project中有聚合任务。很重要)像case类Project(var tasks:Map [String,Task])case class Task(var activities:Map [String,...

回答 1 投票 1

Scala插件与Intellij 2018.3.3不兼容:无法在“新建项目”中选择Scala

我无法在Intellij的“新项目”中选择Scala。 Scala插件与Intellij Ultimate 2018.3.3不兼容。虽然很难找到。我现在真的应该将Intellij降级为......

回答 1 投票 0

Scala - 使用超时重试HTTP请求

我希望创建一个服务,它向特定的URL发出HTTP请求,如果它在1秒内没有得到结果,那么该请求将超时,然后它将重试另一个请求,...

回答 2 投票 1

获取案例类中相同类型的字段值列表

我有一个这样的课程,如果有人感兴趣的话,我会详细解答重叠算法的哪个部分出错了,我希望将来可以用其他许多方法来增强它...

回答 2 投票 1

在IntelliJ中调试sbt项目

我有一个从github克隆的scala项目。我可以使用:sbt'path-to-module'/ run运行它并运行正常。现在我想调试它。怎么做?调试有类似的sbt命令吗? ...

回答 2 投票 0

为什么会导致“类型不匹配”?

def migratoryBirds(arr:Array [Int]):Int = {// var A:Map [Char,Int] = Map()var myMap:Map [Int,Int] = Map()//循环遍历数组for (值

回答 2 投票 0

在Spark Dataframe中的列列表中添加一列rowums

我有一个包含多个列的Spark数据帧。我想在数据帧上添加一列,它是一定数量的列的总和。例如,我的数据如下所示:ID var1 var2 var3 ...

回答 4 投票 16

用mutable.Map和mutable.et折叠使用Set.add时不起作用

我只是想知道为什么我的值分组在下面的代码中不起作用。从技术上讲,Map和Set都是可变的,所以我的add(intValue)应该改变集合(间接聚合器......)

回答 2 投票 0

如何解决类型的Diverging隐式扩展

我想让我的案例类事件[K,V]总是按键K排序。但我需要能够比较不同值的事件V.如何解决这种分歧的隐式扩展?导入scala ....

回答 1 投票 2

scala - 高阶函数将类型T更改为Nothing

故障排除环境:sbt控制台(Scala 2.11.8)和spark-shell(Spark 2.3,Scala 2.11)我有一个带有视图绑定类型T的高阶函数...但是arg t:T类型签名从T&...

回答 1 投票 0

在scala中正确使用Either,Try和Exceptions / ControlThrowable

在我的scala代码(库和应用程序)中,我目前使用Option和Try的混合,只要两者中的任何一个感觉更合适。我倾向于实施“doSomething”方法,这可以......

回答 1 投票 4

Scala:在没有任何特定条件的情况下处理Future.Filter.exists的更好方法

Scala:我只有在前一次返回Some(x)时才需要执行操作。有什么比使用下面的代码更好的方法def tryThis:Future [Option [T]] = {...} val filteredFuture = ...

回答 4 投票 1

Bi的名称 - 具有一个逆变量和一个协变参数的Functor类型类

我正在寻找一个Bi-Functor的标准类型类,它有一个Contravariant参数和一个Covariant参数。打孔签名(c - > a) - >(b - > d) - > f a b ...

回答 1 投票 9

如何从Spark数据帧中的When子句向udf发送多个列?

我想在full_outer_join的基础上加入两个数据帧,并尝试在连接的结果集中添加一个新列,它告诉我匹配的记录,单独的左数据框中的不匹配记录和...

回答 1 投票 1

如何在scalaz中减少Liskov的trans函数?

我是scalaz的初学者。这是源代码:密封抽象类Liskov [-A,+ B] {def apply(a:A):B = Liskov.witness(this)(a)def subst [F [-_]](p:F) [B]):F [A]最终定义* [...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.