scala

5热度

1回答

我已经（OData的）查询参数在我的路线定义，像这样： parameters(('$top.as[Int].?, '$skip.as[Int].?)) { (top, skip) => 我有以下的拒绝处理程序来处理所有无效的参数（handleAll）： RejectionHandler.newBuilder() .handleAll[MalformedQueryParamReject

-1热度

1回答

redis ZADD <keys>在Redis集群环境中是否一致？

是否有可能 - 在redis集群环境中执行ZADD时 - 所有添加的密钥最终都不会同时向所有人提供？我们使用（scala）redis客户端通过ZADD添加一批密钥。然后在X毫秒超时后请求密钥。看起来1个批处理键有时（很少）缺失，并且仅在几毫秒后才可用。我认为，在Redis一致性模型中，要么所有密钥都足够复制，因此可用，否则不显示。因此我不明白如何可能丢失一个单一的密钥。集群环境中的正常R

1热度

1回答

如何从主函数隐藏配置管理？

我有我的切入点是这样的： def main(args: Array[String]): Unit = { pureconfig.loadConfig[Conf] match { case Right(conf) => doStuff(conf) case Left(fail) => lectureUserAboutStuff(fail) } } 所以它

3热度

2回答

声明Scala中的一个通用类方括号

当读取this article我来到了语法如下： implicit val slaveCanRead: Slave HasPrivilege Read = null 作者说：另外，请不说Slave HasPrivilege Read只是另一个符号HasPrivilege[Slave, Read] 保持基本scala中的示例，该示例也可以是 val foo: Map[String, Long]

1热度

1回答

运行sbt新指向内部组织的github

如果我运行sbt new x/y.g8，它提供参数giter8和giter8连接到github.com并下载模板。我想为我的团队内部的团队建立一个模板。我们使用github.company.com作为内部github。无论如何，要让sbt/giter8理解，不仅要搜索github.com，还要搜索github.company.com。我试图指定如以下完整的URL，但它不工作 SBT新http

0热度

2回答

Scala：正则表达式给出“非法重复”错误

我需要在解析文件时找到'} {“_id”。该图案内可能有任何数量的空白或没有空白。我不想替换文件中的任何其他空白区域，除非匹配该模式。我想用'}，{“_ id”'替换。我试图在scala代码和正则表达式它不断给我'非法重复'的错误。正则表达式查找字符串我试图用的是 fileTxt.replaceAll("[\\s]+}[\\s]+{[\\s]+\"_id\"", "},{\"_id\"")

0热度

1回答

在Scala中的网络爬虫算法

我想创建一个算法来以递归方式和以功能方式进行网络爬虫。我知道如何使用for循环，var变量并累积它。但我很努力地递归做它。关于我的代码的一些问题： 1.为什么def loop返回Any？ 2.有一些URL形式为http://..../example.zip，其中getLinksPage引发异常，返回None并中断循环。我该如何处理它？ 3.我如何用一些Scala框架测试来测试这段代码？ de

1热度

1回答

Spark 1.6以空值爆炸

我有一个Dataframe，我试图展平。作为该过程的一部分，我想将其分解，所以如果我有一列数组，则将使用数组的每个值创建一个单独的行。我知道我可以使用爆炸函数。但是，我有一个问题，该列包含空值，我使用火花1.6。下面是数据类型和我想要什么的例子：我的数据： id | ListOfRficAction| RficActionAttachment _________________________

2热度

1回答

如何在sbt-jacoco 3.0.2中配置非托管资源目录？

当前行为我用的是旧版本jacoco过此配置： plugins.sbt addSbtPlugin("de.johoop" % "jacoco4sbt" % "2.1.6") build.sbt ... jacoco.settings unmanagedResourceDirectories in Test += baseDirectory.value/"test/resources"

0热度

1回答

如何延迟附加到另一个akka流的akka流的实现？

的文档FlowOps#concat指出 ...源一起使用这个流程化，并从生产，直到它的时间来断言背压元素只是不停。换句话说，如果我有 sourceA.concat(sourceB) 然后sourceB将在同一时间sourceA物化。我如何推迟sourceB正在实现，直到sourceA完成？我正在使用Akka 2.5.6。