Tag: scala

从java使用scala.collection.immutable.Set的示例: 那些熟悉Scala的人是否知道如何使用Java中的scala.collection.immutable.Set ？我可以模糊地阅读scaladoc，但我不确定如何从java调用scala方法如“ – ”（我假设我只需要在我的类路径中包含一些scala .jar文件……？）

在AKKA中，在主管上调用关闭会阻止它监督的所有演员吗？: 假设我有一个链接了两个演员的主管。当我的应用程序关闭时，我想优雅地关闭这些演员。调用supervisor.shutdown（）会停止所有演员还是我还需要手动停止我的演员？格拉西亚斯

Scala，Java和平等: val filesHere = (new java.io.File(“.”)).listFiles val filesHere2 = (new java.io.File(“.”)).listFiles scala> filesHere == filesHere2 res0：Boolean = false 这非常直观。我宁愿期望filesHere和filesHere2相等。这肯定是由于Java和Scala之间的语义不匹配，例如，关于数组或（文件）相等。显然，我在这里遗漏了一些东西！

处理Spark Scala中的微秒: 我使用Scala将PostgreSQL表作为dataframe导入spark。数据框看起来像 user_id | log_dt ——–| ——- 96 | 2004-10-19 10:23:54.0 1020 | 2017-01-12 12:12:14.931652 我正在转换此dataframe，使log_dt的数据格式为yyyy-MM-dd hh:mm:ss.SSSSSS 。为了实现这一点，我使用以下代码使用unix_timestamp函数将log_dt转换为时间戳格式。 val tablereader1=tablereader1Df.withColumn(“log_dt”,unix_timestamp(tablereader1Df(“log_dt”),”yyyy-MM-dd hh:mm:ss.SSSSSS”).cast(“timestamp”)) 当我打印使用命令tablereader1.show()打印tablereader1dataframe时，我得到以下结果 user_id | log_dt ——–| ——- 96 | 2004-10-19 10:23:54.0 1020 | 2017-01-12 12:12:14.0 如何将微秒保留为时间戳的一部分？任何建议表示赞赏。

如何从sparkdataframe列中的数组中提取值: 我在spark sql中得到了一个这样的dataframe： scala> result.show +———–+————–+ |probability|predictedLabel| +———–+————–+ | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.1,0.9]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.0,1.0]| 0.0| | [0.1,0.9]| 0.0| | [0.6,0.4]| 1.0| | [0.6,0.4]| 1.0| | [1.0,0.0]| 1.0| […]

play2框架我的模板没有看到。：package views.html不存在: 问题是控制器没有看到我想要使用的模板： [etl_admin] $ compile [info]将3个Scala源和4个Java源代码编译为D：\ ECLIPSE_WORKSPACES \ play2_apps \ etl_admin \ target \ scala-2.9.1 \ classes … [错误] D：\ ECLIPSE_WORKSPACES \ play2_apps \ etl_admin \ app \ controllers \ EtlWorkflowSeqNodeController.java：7：错误：包views.html.etlworkflowseqnode不存在[error] import views.html.etlworkflowseqnode.list; [错误] ^ [错误] D：\ ECLIPSE_WORKSPACES \ play2_apps \ etl_admin \ app \ controllers \ EtlWorkflowSeqNodeController.java:14:error：找不到符号 [error] list.render（EtlWorkflowSeqNode.findTree（jobId））[错误] ^ [错误]符号：变量列表[错误] location：class EtlWorkflowSeqNodeController [error] 2 […]

单次迭代=>从Java到Scala的多个输出集合: 我目前正在尝试将一些Java代码转换为Scala代码。面临的挑战是确保转换后的Scala代码与原始Java代码相比，最终不会产生非常低效的代码。例如，当尝试转换以下代码时： class Person { String name; Integer age; Character gender; } public class TestJava { public static void main(String[] args) { final List persons = new ArrayList(); final List males = new ArrayList(); final List aNames = new ArrayList(); final List seniors = new ArrayList(); for (final Person p: persons) { if (p.gender […]

scala.concurrent.forkjoin.ForkJoinPool vs java.util.concurrent.ForkJoinPool: 为什么ForkJoinPool是为Scala分叉的？哪种实施方式以及哪种情况首选？

Scala：class级中的公共静态决赛: 我试图在Scala中使用TwiP获得Java的public static final 版本。在object中创建val对我来说不起作用，因为它是新生成的类的一部分。 Example$.class和TwiP无法从类Example.class访问它。这是我尝试移植到Scala的Java类的示例： public static final String[] MY_STRINGS = { “A”, “B”, “C” }; @Test public void myTest(@Values(“MY_STRINGS”) String string) { … } 但我不知道如何将public static final移植到Scala。如果它是像这里的对象中的val @RunWith(classOf[TwiP]) class Foo { import Foo.MY_STRINGS @Test def testTwiP(@Values(“MY_STRINGS”) value: String): Unit = { println(“I’m testing value ” + value + “.”) } […]

通常使用Scala闭包实现Java Single-Abstract-Method接口？: 据我了解，当它们最终出现时，我们将能够用Java闭包代替等效的单方法接口。是否有标准的Scala习惯用法 – 使用Scala闭包实现Java Single Abstract Method接口？理想情况下，我希望以下内容能够实现自动化 test(“Closure”) { var event: PropertyChangeEvent = null var label = new JLabel() label.addPropertyChangeListener( {e: PropertyChangeEvent => event = e} ) label.setText(“fred”) event.getNewValue should be (“fred”) }