scala

    1热度

    1回答

    基本上这里是我使用的代码。 当我用curl进行连接时,我发现curl命令中的所有实体都非常快。当我尝试模仿与akka相同的行为时,打印出我得到的元素之间会有很大的停顿。 流动波纹管在某种程度上受到了压力,并且在前4条消息之后,1条消息的其余部分会在明显的打印线之后到达。 前4条消息大约是2k JSON,最后一条没有。 5是80k JSON。 最后一个实体(编号5)也是最大的块,我得到它在流完成之前

    0热度

    2回答

    在我的播放应用程序中使用cacheApi,我想知道我是否可以有一些超时缓存清理? 进出口使用的cacheApi对象的方法if the data is in cache bring from cache, if not, so go get it from the server with an api call ,现在我想每24个小时清理缓存,能够从服务器带来了新的数据。 我是如何完成这样的事情的?

    5热度

    1回答

    假设我们有以下的文本文件(df.show()命令的输出): +----+---------+--------+ |col1| col2| col3| +----+---------+--------+ | 1|pi number|3.141592| | 2| e number| 2.71828| +----+---------+--------+ 现在我想读/解析它作为一个数据帧/

    3热度

    2回答

    我想创建一个Int值存储这样的一个类型级表示: sealed trait Position { def value : Int } class P1 extends Position {val value = 1} class P2 extends Position {val value = 2} 当一个类继承它: case class PExtended() extends

    1热度

    2回答

    我有一个表包含一列“年龄”。我想根据他们的年龄分组人群,EX:[0,5],[5,10],[10,15],... 然后我会为每个组做同样的计算并比较结果。 这样做的目标是查看年龄是否与其他变量有关。 请帮忙。

    0热度

    1回答

    读取Spark文档的第一个函数,它提到ignoreNulls会得到第一个非空值。 import org.apache.spark.sql.SparkSession import org.apache.spark.sql.functions._ import org.apache.spark.sql.expressions.{Window, WindowSpec} object tmp {

    1热度

    1回答

    我正在构建mongodb对象并将它传递给mongo存储库的findAll方法。 如何通过围绕所有这些领域设计索引来实现更快的性能? val criteriaQuery = MongoDBObject.newBuilder criteriaQuery += OrderNames.CLIENT_ID -> clientId if (StringUtils.isNotBlank(orderId))

    0热度

    1回答

    我遇到以下scala示例,它解释了aggregateByKey。 斯卡拉例:以上Scala代码 val pairs=sc.parallelize(Array(("a",3),("a",1),("b",7),("a",5))) import scala.collection.mutable.HashSet //the initial value is a void Set. Adding an

    0热度

    2回答

    我是scala的新手,我正在尝试创建一个代码尚未完成的树。这是我做了什么: class Tree { class TreeNode(val n: Int, val points: Array[Double], val center: Double) extends Tree{ } sealed trait Tree { def elem : TreeNode } def

    1热度

    1回答

    我试图启动一个卡夫卡服务器形式的Java 具体来说,我怎么能翻译斯卡拉的this line入行渣华的? private val server = new KafkaServer(serverConfig, kafkaMetricsReporters = reporters) 我可以轻松地创建serverConfig中,但我似乎无法能够创建kafkaMetricsReporters参数。 注:我