Tag: scala
为什么Cassandra客户端在没有epoll的情况下失败？
当我在本地运行我的服务时，我收到epoll不可用的警告，因此它正在使用NIO。 很公平。 当我在Kubernetes中部署它时，我得到了这个，这阻止了服务运行： 2017-03-29T19:09:22.739482458Z 19:09:22.739 WARN com.datastax.driver.core.NettyUtil – Found Netty’s native epoll transport in the classpath, but epoll is not available. Using NIO instead. 2017-03-29T19:09:22.739505903Z java.lang.UnsatisfiedLinkError: could not load a native library: netty-transport-native-epoll 2017-03-29T19:09:22.739509966Z at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:224) 2017-03-29T19:09:22.739513326Z at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:269) 2017-03-29T19:09:22.739516421Z at io.netty.channel.epoll.Native.(Native.java:64) 2017-03-29T19:09:22.739519628Z at io.netty.channel.epoll.Epoll.(Epoll.java:33) 2017-03-29T19:09:22.739522527Z at java.lang.Class.forName0(Native Method) 2017-03-29T19:09:22.739525253Z at java.lang.Class.forName(Class.java:264) 2017-03-29T19:09:22.739528047Z at com.datastax.driver.core.NettyUtil.(NettyUtil.java:68) […]
如何将long（currentTimeInMillis）转换为UTC时间戳？
我的客户送我Long ，这可以被认为是 scala> System.currentTimeMillis res3: Long = 1441056836609 scala> 如何将其转换为UTC timeStamp？ 在Server上，我们使用的是Java 8
Play Framework多租户filter
我正在尝试使用Play Framework 2.2构建一个多租户应用程序并遇到了问题。 我想在全局onRouteRequest （或Java中的onRequest ）中设置一个会话密钥，用于标识用户请求的域的站点ID。 在几十个其他框架中，这种类型的东西是无痛的（例如Django），但我知道Play中的会话对象显然是不可变的。 所以，现在，我有这样的事情： override def onRouteRequest(request: RequestHeader): Option[Handler] = { if (request.session.get(“site”).isEmpty){ val id = models.Site.getSiteUIDFromURL(request.host.toLowerCase()).toString() if (!id.isEmpty){ //what goes here to set the session? }else{ //not found – redirect to a general notFound page } } super.onRouteRequest(request) } 而且，虽然它不是使用数据库查找的最有效方式，但它现在可用于测试。 我需要能够在全局设置会话密钥，但我完全不知道如何做到这一点。 如果有更好的方法，我全都耳朵（也许包裹我的控制器？）。 我对Java或Scala中的解决方案示例持开放态度。
如何将此（github）源代码转换为库/ jar？
我想使用这个来源： https ： //github.com/mongodb/casbah如何使用这些东西？ 我想为图书馆制作一个jar子。 但我不知道怎么做。 用Eclipse和IntelliJ试了一下。 我下载了源代码： git clone git://github.com/mongodb/casbah 现在我有一个casbah文件夹; 我将它复制到项目源（在Eclipse或IntelliJ中），但我甚至无法编译它…总是有类似的东西： error: ‘{‘ expected but identifier found. package casbah-dynamic.src.main.scala 我需要编译吗？ 怎么样？ 编译后会发生什么？ 这是一个Scala项目，但我认为这不是那么重要。 作为一个Java项目，我必须做同样的事情。 所以我该怎么做？ 编辑：我看到这些东西是存在的（它们的某些部分）作为一个jar子（ http://scala-tools.org/repo-releases/com/mongodb/ ）。 但我想使用源代码并学习如何使用它。
如何知道Option ]]是否包含密钥？
我想知道request.body.asFormUrlEncoded包含deviceId 。 val formValues=request.body.asFormUrlEncoded val number = formValues.get(“mobile”).head var deviceId =”deviceIdNotFound” if(condtion) //thats the problem deviceId= formValues.get(“deviceId”).head 对于Option[Map[String,Seq[String]]]有任何conatins或任何其他函数的方法吗？
如何确保字符串是UTF-8？
如何将此String the surveyÂ’s rules转换为Scala中的UTF-8 ？ 我尝试过这些道路，但不起作用： scala> val text = “the surveyÂ’s rules” text: String = the surveyÂ’s rules scala> scala.io.Source.fromBytes(text.getBytes(), “UTF-8″).mkString res17: String = the surveyÂ’s rules scala> new String(text.getBytes(),”UTF8”) res21: String = the surveyÂ’s rules 好的，我这样解决了。 不是转换，而是简单的阅读 implicit val codec = Codec(“US-ASCII”).onMalformedInput(CodingErrorAction.IGNORE).onUnmappableCharacter(CodingErrorAction.IGNORE) val src = Source.fromFile(new File (folderDestination + name + “.csv”)) val […]
Play Framework – 向classpath添加新目录
我希望能够有一个单独的目录，其中代表插件的jar文件可以添加到Play 2.0项目中。 Jar文件通常保存在Play中的/ lib目录下。 我想将我的jar分隔在名为/ plugins的目录中 之前曾问过这个问题，但建议只使用/ lib目录。 将其他java文件添加到playframework类路径 如果不手动更改Play生成的“eclipsified”文件，是否无法执行此操作？
连接到远程Spark master – Java / Scala
我在AWS中创建了一个3节点（1个主节点，2个工作节点） Apache Spark集群。 我可以从主服务器向集群提交作业，但是我无法远程工作。 /* SimpleApp.scala */ import org.apache.spark.SparkContext import org.apache.spark.SparkContext._ import org.apache.spark.SparkConf object SimpleApp { def main(args: Array[String]) { val logFile = “/usr/local/spark/README.md” // Should be some file on your system val conf = new SparkConf().setAppName(“Simple Application”).setMaster(“spark://ec2-54-245-111-320.compute-1.amazonaws.com:7077”) val sc = new SparkContext(conf) val logData = sc.textFile(logFile, 2).cache() val numAs = logData.filter(line => line.contains(“a”)).count() val […]
用于实现分布式消息传递算法的编程语言
基本上，我想实现以下算法并分析使用这些算法构建的系统在不同条件下的行为。 八卦协议 多个paxos 一致的散列 我的兴趣在于这些算法。 我基本上正在寻找一种编程语言，可以让我快速编写这些算法并深入理解这些算法。 我应该选择哪种语言？ Java，Scala，Erlang或其他任何东西。 目前，我了解Java和C ++。
从Scala实现具有Raw类型的Java接口
我正在尝试使用Scala为Sonar构建扩展。 我需要扩展以下Java接口： public interface Decorator extends BatchExtension, CheckProject { void decorate(Resource resource, DecoratorContext context); } 但资源类型实际上定义如下： public abstract class Resource 我知道我可以解决创建Java原始超类的问题。 我想坚持Scala-only，也知道我是否缺少一个解决方案，以及是否有一个改进我可以向SonarSource人员建议他们（使用原始类型）。 我已经阅读过这方面存在的问题，以及某些情况下的一些解决方法，但似乎没有适用于此处（ 一种解决方法 ， 一张明显固定的机票 ，还有2091的机票…）
