Tag: scala

如何将sql数组值从java控制器传递给scala模板

我是新玩的框架。 我想将java控制器中的数组变量传递给scala模板。 try { String userName = “data”; String password = “data”; String url = “jdbc:mysql://localhost/playdb”; // Class.forName(“com.microsoft.sqlserver.jdbc.SQLServerDriver”); Connection con = DriverManager.getConnection(url, userName, password); Statement stmt = con.createStatement(); System.out.println(“Connected database successfully…”); String strSelect = “select * from computer”; //statement.setString(1, name); ResultSet rset = stmt.executeQuery(strSelect); while(rset.next()) { // Move the cursor to the next row String […]

在Java中使用Scala 2.10.1值类型

我正在将2.9。*项目更新为2.10。 我有几个基本类型（角度，长度等）的类，看起来它们是值类型的完美候选者。 不幸的是，我使用这些类型的Java代码没有编译，我无法弄清楚原因。 我把它简化为一组非常简单的代码。 任何建议将不胜感激。 角度类定义（scala） package com.example.units class Angle(val radians : Double) extends AnyVal { def degrees = radians * 180.0 / math.Pi } object Angle { val Zero = new Angle(0) } 角度测试用例（用Java编写的痛苦） package com.example.units; import junit.framework.Assert; import org.junit.Test; public class AngleTest { @Test public static void TestZero() { Angle a = Angle.Zero(); […]

Spark 2.0.1写入错误：引起：java.util.NoSuchElementException

我试图将情绪值附加到每个消息，我已经下载了所有stanford核心jar文件作为依赖项： import sqlContext.implicits._ import com.databricks.spark.corenlp.functions._ import org.apache.spark.sql.functions._ val version = “3.6.0” val model = s”stanford-corenlp-$version-models-english” // val jars = sc.listJars if (!jars.exists(jar => jar.contains(model))) { import scala.sys.process._ s”wget http://repo1.maven.org/maven2/edu/stanford/nlp/stanford- corenlp/$version/$model.jar -O /tmp/$model.jar”.!! sc.addJar(s”/tmp/$model.jar”)} val all_messages = spark.read.parquet(“/home/ubuntu/messDS.parquet”) case class AllMessSent (user_id: Int, sent_at: java.sql.Timestamp, message: String) val messDS = all_messages.as[AllMess] 到目前为止，一切都很好，因为我可以执行计算并保存DS case class AllMessSentiment = […]

如何在DDD中实现持久无知？

我正在处理涉及Workspace的项目的持久层，每个项目可能包含零个，一个或多个Document 。 （我试图遵循领域驱动设计原则，但我的问题可能与此没有直接关系。） 问题1：我应该分离出持久性吗？ 即，您是否以这样的方式设计实体和价值类 在内存中创建实体和值，就像没有持久性一样（可能使用Factory方法Workspaces.newWorkspace(…) ），以及 调用一个单独的persist()方法（可能在存储库中）来处理持久性？ 或者我的工厂方法Workspaces.newWorkspace()应该创建一个持久化实体（一旦事务关闭就会持久化）？ 如果这个问题的答案是“分离，伙计！” 然后我想知道如何以优雅的方式实现这一目标。 我的第一种方法是（在Scala伪代码中）： class Workspace(title: String, documents: List[Document], id: Option[Long]) { def add(d: Document) = // … def remove(d: Document) = // … } 但是，如果工作空间可以包含许多文档，则这不是很好（受RAM限制）。 我的下一个方法是“如何不向实体注入服务” ，这是： class Workspace(title: String, docSupplier: DocSupplier, id: Option[Long]) { def add(d: Document) = docSupplier.add(d) def remove(d: Document) = docSupplier.remove(d) } […]

使用scala运行openIE时出错

我在scala中运行openIE。 在运行sbt run时我遇到了错误。 任何机构都能解释一下 将当前项目设置为openie（在构建文件中：/ home / user_name / Videos / openie-master /） [info] Running edu.knowitall.openie.OpenIECli [error] Exception in thread “main” java.lang.NoSuchFieldError: MODULE$ [error] at scala.util.PropertiesTrait$class.scalaPropOrNone(Properties.scala:65) [error] at scala.util.Properties$.scalaPropOrNone(Properties.scala:16) [error] at scala.util.PropertiesTrait$class.$init$(Properties.scala:77) [error] at scala.util.Properties$.(Properties.scala:16) [error] at scala.util.Properties$.(Properties.scala) [error] at scala.compat.Platform$.(Platform.scala:112) [error] at scala.compat.Platform$.(Platform.scala) [error] at scala.App$class.$init$(App.scala:42) [error] at edu.knowitall.openie.OpenIECli$.(OpenIECli.scala:29) [error] at edu.knowitall.openie.OpenIECli$.(OpenIECli.scala) [error] at […]

使用scala获取当前计算机的公共IP地址

我想获得一个IP地址，可以使用scala在我的机器或局域网外部访问。 用例场景：Web服务正在计算机上运行。 在其响应中，它应该返回其端点之一的URL。 所以现在我必须提供运行Web服务的机器的IP 我使用NetworkInterface.getNetworkInterfaces（）来获取主机上所有已知的网络接口，然后迭代每个NI的地址。 但在这种情况下，我得到了许多IP地址。 如何从所有这些中找出正确的IP。 以下是scala中的代码段： private def ipAddress: String = { val enumeration = NetworkInterface.getNetworkInterfaces.asScala.toSeq val ipAddresses = enumeration.flatMap(p => p.getInetAddresses.asScala.toSeq ) val address = ipAddresses.find { address => val host = address.getHostAddress host.contains(“.”) && !address.isLoopbackAddress && !address.isAnyLocalAddress && !address.isLinkLocalAddress }.getOrElse(InetAddress.getLocalHost) }

特征和接口二进制兼容吗？

我很惊讶Scala在不同版本中是二进制不兼容的事实。 现在，因为在Java 8我们有默认的方法实现，它与我们提供的trait几乎相同，是否可以安全地在Java代码中使用特征？ 我自己尝试使用它： trait TestTrait { def method(v : Int) def concrete(v : Int) = println(v) } public class Test implements TestTrait{ // Compile-error. Implement concrete(Int) @Override public void method(int v) { System.out.println(v); } } 但它拒绝编译。 编译器抱怨没有混淆concrete(Int) 。 虽然我在TestTrait指定了实现。

不支持的密码套件TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256

我最近收到了Commodo的证书，我正在尝试将它与我的Scala Spray Server集成。 我有一个特性来配置我的Spray服务器： import java.io.{BufferedInputStream, FileInputStream} import java.security.{SecureRandom, KeyStore} import java.security.cert.{X509Certificate, CertificateFactory} import javax.net.ssl.{TrustManagerFactory, KeyManagerFactory, SSLContext} import spray.io._ import org.apache.camel.util.jsse._ // for SSL support (if enabled in application.conf) trait MySSLConfig { // if there is no SSLContext in scope implicitly the HttpServer uses the default SSLContext, // since we want non-default settings in this […]

动态编程中的第n个Fibonacci数

每个人都知道斐波那契系列的逻辑 Fib0 = 0 Fib1 = 1 Fibn = Fibn-1 + Fibn-2 , n > 1 我的问题是我必须计算fib(n)%(100000000+7) ， 输出应该是n 比如for n=0 output 1 for n=5 output 5 for n=10 output 55 for n=100 output 24278230 我在scala使用tail recursion成功编写了它 def fi( n : Int) : Long = { def fib_tail( n: Int, a:Int, b:Int): Int = n […]

Java中的“Lambdifying”scala函数

使用Java和Apache Spark（已经在Scala中重写），面对旧的API方法（ org.apache.spark.rdd.JdbcRDD构造函数），它有AbstractFunction1作为它的参数： abstract class AbstractFunction1[@scala.specialized -T1, @scala.specialized +R]() extends scala.AnyRef with scala.Function1[T1, R] {} 因为AbstractFunction1是一个抽象类，所以我不能使用Java8 lambdas，所以我决定用scala.Function1 trait包装java.util.functions.Function是相同的但是没有实现andThen和compose方法。 结果，我创建了thes接口： import scala.Function1; @FunctionalInterface public interface Funct extends Function1, Serializable { @Override default Function1 compose(Function1 before) { return null; } @Override default Function1 andThen(Function1 g) { return null; } } IDE对此接口没有任何问题，但在编译时，get： [ERROR] Funct is not a functional […]