-
了解Scala播放框架中的展开和取消应用
在<a href="https://www.manning.com/books/play-for-scala" rel="nofollow noreferrer">"Play for Scala book"</a>清单8.12中 < -
spark-submit:java.lang.NoSuchMethodError:org.apache.spark.SparkContext $。$ lessinit $ greater $ default $ 6()Lscala / collection / Map;
我正在Spark上运行一个简单的Scala示例。在这一行: <pre class="lang-scala prettyprint-override"><code>val sc = new -
Spark Streaming应用程序上的多个writestream
在我的Spark流应用程序中,我试图从Azure EventHub流化数据,然后根据该数据写入hdfs blob中的几个目录。基 -
如何在Spark Scala中找到数据框的组合差异?
例如: <pre><code>+------+ |items | +------+ | 1| | 14| | 11| | 3| | 0| | 0,13| | 8| | 7| | 7,11| | -
Spark:读取表并按分区过滤
我试图了解Spark的评估。 有一个表table_name,该表由partition_column分区。这是一个以实木复合地板格 -
使用Scala从HBase读取数据时出错
我只是火花的初学者。 我试图连接到名为mimic3的Hbase myDB表,该列族称为sepsiscategories,并且有很多列。 -
生成的播放json隐式实例导致StackOverflowError
我有以下代码: <pre><code>import play.api.libs.json._ object Test { sealed trait T case class A(s: String) extends T -
scala-logging不会创建日志文件
我正在尝试使用scala-logging从Linux上运行的Scala / Spark项目进行日志,并通过spark-submit在Spark集群上启动。 -
如何从Source [ByteString,Any] akka流中实现2个参数
这样我就可以从Source [ByteString,Any]中实现inputStream和Feature [ByteString] <pre><code>val bs = fileStream.runWith(Si -
将字符串转换为列表列表
输入(字符串): <pre><code>[[0_busswvan, 24.0, 2019-09-05 20:15:33],[05f9acb08d7c11e89e8fede614b72917, 20.0, 2019-09-05 14: -
Scala:交换字符串中每个字符的大小写
使用Scala,我想要一个初始字符串的子字符串并交换每个字符的大小写,以使大写字母变为小写,小写变 -
Slick flatMap不能将所有查询作为一个组执行
我发现Scala Slick无法将多个查询作为纯SQL执行。 例如: <pre><code>val query = sql""" SET @re -
Intellij:调试不适用于Play框架
一段时间以来我在Intellij(最终版2019.2)中进行调试时遇到问题。 如果我设置了断点并重新启动Int -
以编程方式运行scala测试“ Spec”文件
我有一个<code>Spec</code>子类B,它扩展了另一个<code>Spec</code> A,并且我希望每当我运行A测试文件时,B中 -
如何使用ReactiveMongo事务将文档写入MongoDB?
我正在尝试运行此简单代码,该代码将一个文档插入到事务下的“报告”集合中。 这是代码: -
将值从一个笔记本传递到另一个笔记本-Databricks
我正在从databricks连接到Azure SQL Server,为此我正在使用jdbc连接器 <pre><code>val jdbcUsername = "user1" v -
在脱机Windows计算机上安装sbt
我有一台以前安装了sbt 0.13.X的脱机Windows机器,它知道我们最初是如何安装它的。 我们决定将计算机的sb -
如何检查Scala中所有列表元素是否都不同?
我有一个<code>List[(Int, Int)]</code>,我想检查列表中的所有元素是否<strong>不同</strong>。 如何在Scala -
可以在Spark的Cosmos DB Connector中使用Mongo Shell样式查询吗?
我正在使用Cosmos DB Connector for Spark。是否可以通过Cosmos DB连接器使用Mongo Shell“ JSON样式”查询而不是SQL -
列出坐在数据湖中的文件夹中的所有文件
我试图获取一个文件夹中所有文件的清单,该文件夹包含几个子文件夹,所有这些子文件夹都位于一个 -
提供Seq的获取实例
例如,我有一些带有一些参数的实体,以及两个表示该实体的数据库表: <pre><code> entity -
如何使用Scala从json配置文件中读取对象数组
我的json文件如下: <pre><code>{ "array":[ { "name": ["na"], " -
如何发布包含依赖项的SBT项目的测试,以及如何导入另一个项目
在项目<code>A</code>中,启用了以下SBT选项: <pre><code>publishArtifact in (Test, packageBin) := true </code></pre> -
火花UDAF,用于在组级别并行处理数据帧,但在每个组中依次处理行
我们在<a href="https://stackoverflow.com/questions/58439080/spark-sql-how-to-achieve-parallel-processing-of-dataframe-at-group-level-b -
加特林坡道用户和活动用户
我在加特林负载测试中使用(120)上的rampUsers(20)。但是我得到了以下结果 <a href="https://i.stack.imgur.com/ -
如何将Spark Dense Matrix转换为Spark Dataframe
我正在尝试在Scala Spark中实现一些代码,其中我有一个多类Logistic回归模型,并且该模型生成系数矩阵。 -
依赖项注入模块初始化顺序中Dev和Prod模式之间的差异
我有一个Play应用程序,并且正在使用DI的Play库,而Guice开箱即用。 我正在定义的一些播放模块相 -
在使用精炼
我试图使用精致的来基于基元创建智能构造函数,并避免包装,因为在大型集合中可能使用相同的类型 -
如何将数组元素映射到Spark Dataframe中的每个记录
我正在处理一个看起来像这样的数据框- <pre><code>val df = Seq( (0.0 ), (0.0 ), (0.0 ), (0.317), (0.0 ), (0.0 ), -
scala.math.BigDecimal:1.2和1.20相等
在将Double或String转换为scala.math.BigDecimal时,如何保持精度和尾随零? 用例-在JSON消息中,属性的