scala

2热度

1回答

我目前正在努力与scala未来回调的逻辑。我试图让这应该做的方法如下：与x值完成对如果x与失败的异常成功完成完成与值y如果x失败，终于完成对y如果x和y失败。这里是我的代码，因为某些原因无法正常工作： def eitherF(x: Future[Int], y: Future[Int]): Future[Int] = { var ret : Future[Int] = x

0热度

1回答

如何使用Ammonite Ops更改某个目录并在其中执行操作？

我正在玩Ammonite操作系统，并希望自动化在git repos上做'git pull'。我无法弄清楚如何更改为特定的目录（这里我想做一个混帐拉），因为文档说 - 没有内置业务来改变cwd。一般而言，你不需要：简单地定义一条新路径，例如val target = cwd /'target对于大多数需求应该足够了。尽管上面提到的解决方案也是如此，但我还是无法达到预期的效果。

0热度

1回答

sc.parallelize不是在ML管道与训练算法工作

随着org.apache.spark.mllib学习算法，我们用来设置管道没有训练算法 var stages: Array[org.apache.spark.ml.PipelineStage] = index_transformers :+ assembler val pipeline = new Pipeline().setStages(stages) 然后经过我们二手LabeledPoi

1热度

2回答

Scala的正则表达式：从送礼者字符串获得价值

所以我有这样的string： val str = "\n Displaying names 1 - 20 of 273 in total" ，我想返回Int名称的总数，在我的例子：273

4热度

2回答

泛函的方式找到空的间隔在开始和结束时间的元组的列表

说我有一个开始和结束时间的元组的列表： List((1,10), (2,11), (3,11), (13,14)) 唯一的放松是启动时间提升我期待以下的输出： List((0,1), (11,13)) 的程序执行是相当简单的，但我不会有一个线索，要做到这一点（惯用）功能。 scala-for-yield循环似乎是不合适的，因为结果将与输入大小相同。而减少/折叠会限制我只有一个元组作为答案

2热度

2回答

什么时候ExecutionContext＃reportFailure（Throwable）被调用？

这是一个相当普遍的问题，但希望是一个合理的问题。什么时候叫ExecutionContext#reportFailure(Throwable)？它似乎没有在Scala标准库中调用。我想我应该在某些情况下调用它？这些是什么？

1热度

1回答

Intellij安装scala和spark

我有Intellij IDEA社区版。我需要为配置用于IntellJ的Apache Spark提供帮助。我想Scala..I使用crealytics获得来自GA数据.. 我build.sbt： name := "scala-project-test" version := "1.0" scalaVersion := "2.11.8" libraryDependencies ++= Se

0热度

2回答

获取类字段

例如我的情况类是 case class Test(id: String, myValues: List[Item]) case class Item(id: Long, order: Long) ，我得到这样 val checkValue: String = "id" 我想排序项测试的字符串值，我希望它看起来像 val test= Test("0", List(Item(0, 14),

-1热度

1回答

如何将目录中的所有文件移动到hadoop中的另一个

我正试图使用spark scala将所有文件从目录移动到HDFS中的另一个目录。总之，我需要以程序化的方式找到使用hadoop fs -mv命令的方法。正如我对hadoop新手一样，如果有人能够提供帮助，这将会很棒。

1热度

3回答

斯卡拉 - 使用参数化类型参数化类型

里面我试图编译下面的代码： case class Settings(settingsList:List[Setting]) abstract class Setting[T](name:String, value:T) 但是编译器会抱怨： Error:(9, 54) class Setting takes type parameters case class Settings(settin