scala

    0热度

    2回答

    当我尝试推出SBT,我得到以下信息: ~(501)$sbt (standard_in) 1: parse error No java installations was detected. Please go to http://www.java.com/getjava/ and download 然而,Java和斯卡拉安装 ~(508)$java -version java ver

    1热度

    1回答

    我是新来的scala和sbt的东西,所以我不知道为什么我得到的错误。 ,以下是我build.sbt name := "graphx-example" version := "1.0" scalaVersion := "2.11.8" libraryDependencies ++= Seq( "com.typesafe" % "config" % "1.3.1", "o

    0热度

    1回答

    我正在使用Scala 2.11和Akka Streams Kafka 0.17。 我有一个流其中: 甲Source使用Source.actorRef创建。在这里,演员计划以固定间隔运行并持续生成消息,并将消息发送到流中。 我已附加Producer作为Flow。制片人推动ProducerMessage.Message成为卡夫卡话题。 一些数据库操作。 我有一个问题,同时构建ProducerMessa

    0热度

    1回答

    阅读akka流的文档,我不太清楚诸如消息顺序之类的东西,以及我是否可以执行它。让我用我为聊天服务器编写的一小段代码来设置我的问题的上下文。 def flowShape(user: User) = GraphDSL .create(Source.actorRef[ChatMessage](bufferSize = 5, OverflowStrategy.fail)) { impl

    0热度

    2回答

    查找我做的火花项目和需要就如何解决的最佳方式如下问题: 我有一个数据帧(说MainDF),其中有上百万的记录。格式是这样的(name:String,value:Int)。下面的内容例如: Davi,130 Joel,20 Emma,500 我还有一个小文件,与4号线的记录,像这样(的className:字符串,minValue(最小值):诠释,包括maxValue:智力) 现在我需要创建通

    1热度

    2回答

    我学习Scala +阿卡,我想在我的 小类中添加文件记录功能,我使用的IntelliJ IDEA 这是我做了什么: 新增依赖性build.sbt内的src/main/resources目录 创建application.conf文件 创建logback.xml文件 application.conf文件: akka { loggers = ["akka.event.slf4j.Slf4jLo

    0热度

    1回答

    我想更新这样的表完整行: UPDATE tracks SET random_sorting = (CAST(RAND() * 100000 AS UNSIGNED) + 1) 但我不知道该怎么做,在油滑不通过每一行迭代。 有没有办法做到这一点?

    2热度

    5回答

    我最近一直有问题,因为我的依赖项已更新为使用netty 4.1,而Gatling尚未更新一段时间,并且仍然只能在Netty 4.0上运行。 任何人都知道Gatling的任何替代方法来创建类似的性能测试的模拟和场景,以便在我的Maven生命周期中自动运行吗?

    1热度

    1回答

    我不确定我想实现的是否可能。我所知道的是,我正从一个执行器访问单例对象,以确保它的构造器在每个执行器上只被调用一次。这种模式已经在我的代码库中被证明和按照预期用于类似的用例。 但是,我想知道的是,如果我可以在驱动程序初始化之后运送对象。在这种情况下, 访问ExecutorAccessedObject.y时,理想情况下它不会调用println,而是返回值。这是一个高度简化的版本,实际上,我想打电话给

    2热度

    2回答

    有没有人知道如何使用无形的测试工作。 package net.jtownson.swakka.jsonschema import org.scalatest.FlatSpec import org.scalatest.Matchers._ class OptionalFieldSpec extends FlatSpec { case class A(i: Int, j: Op