scala

1热度

2回答

我解析Scala中使用SnakeYAML这样这个YAML文件 View: from : 01.01.2007 to : 04.01.2007 driver : sun.jdbc.odbc.JdbcOdbcDriver 转储嵌套列表： val stream = getClass.getResourceAsStream("/config_view.yml") var

0热度

1回答

播放2.5应用程序请求挂起

我正在运行一个小scala使用激活运行在流浪盒上以dev模式播放应用程序。当从浏览器访问应用程序时，一些请求会无限期地挂起来。这似乎与此问题中播放2.0 Play Framework Hanging when hitting app in browser所述的问题相同。然而，建议的解决方案似乎并不适用于最新版本的游戏。我不确定从哪里开始调查此问题。任何帮助将不胜感激！

2热度

2回答

您建议使用哪种Scala框架来构建带有Cassandra后端的REST API？

我想在Scala中构建带有Cassandra后端的REST API，但由于有许多框架可用，而且有些框架对NoSQL数据库有限制，所以我想知道更好的框架选择是什么。

0热度

1回答

将键值对的字符串转换为JSON字符串（Scala）的习惯方式

我试图将键值对的字符串转换为JSON字符串。关于KV对串的唯一知识是串的格式，即分隔空间，逗号分隔等等。对于例如我无法控制作为输入进入的键的数量或类型。这是我想出来的，并且想看看这种方法看起来是好的还是令人敬畏的/尴尬的。如果有比这更好的替代方案，将不胜感激。 INPUT : clientIp="1.1.1.1" identifier="a.b.c" key1=10 key2="v3" fi

1热度

1回答

火花 - 通过输出从组中删除CompactBuffer（RDD）

问题陈述需要分组的RDD 输入 Header1^Header2 A^4B A^11A B^7A C^6DF C^7DS 后火花输出（删除CompactBuffer）格式化所需输出 (A,(4B,11A)) (B,(7A)) (C,(6DF,7DS)) 我有什么企图 val records = sc.textFIle("/user/chronicles/test.txt").

1热度

1回答

解析来自Kafka流的JSON RDD时的Java Execption

我想从使用Spark流库的kafka读取json字符串。该代码能够连接到kafka代理，但在解码消息时失败。该代码是从 https://github.com/killrweather/killrweather/blob/master/killrweather-examples/src/main/scala/com/datastax/killrweather/KafkaStreamingJson.s

0热度

1回答

不能在斯卡拉

突围foreach循环的，我有这个下面的代码 > .foreach("${plist}", "newshole") { > exec( > http("get the user id") > .get("${newshole}/jcr:content.1.json") > .headers(headers_2) > .check(bodyString.saveAs("Re

2热度

1回答

星火据帧UDF无

我试图延长sparkml带有过滤器变压器管道模型TypeTag，后 abstract class RuleFilter[IN, T <: RuleFilter[IN, T]] extends RuleTransformer with HasInputCol { // def filterFuntion: String /** @group setParam */

1热度

1回答

使用sprayJSON（scala）添加字段到现有的JSON对象

我做了一个case类来存储我的一些数据。此案类如下所示： case class Job(id: Option[Int], title: String, description: Option[String], start: Date, end: Option[Date], customerId: Int) 我用下面的格式写/读我的JSON对象： implicit val job

3热度

2回答

如何覆盖sbt中某些任务的依赖关系

我想在某些任务中覆盖项目的依赖关系。我有一个使用spark的sbt多项目。 lazy val core = // Some Project val sparkLibs = Seq( "org.apache.spark" %% "spark-core" % "1.6.1" ) val sparkLibsProvided = Seq( "org.apache.spark"