我有一个到Oracle DB的JDBC连接。我还有一些用Groovy或Scala编写的函数f(x)。例如，f(x)只返回2x。现在我的问题是:我应该如何在Java代码中调用f(x)，将f(x)应用于一列中的所有值，并在上面的示例中将该列更新为2x？
浏览 4提问于2017-06-13得票数 0
我有一个用Scala编写的UDF，我希望能够通过Pyspark会话调用它。UDF有两个参数，字符串列值和第二个字符串参数。如果UDF只需要一个参数(列值)，我就可以成功地调用它。如果需要多个参数，我很难调用UDF。中使用它时，我已经能够注册并使用这个UDF：val udfInstance = new SparkUDFTest()
val stringLength
浏览 1提问于2018-02-12得票数 2
1回答
我有一个usecase，其中我想从一个Oracle表中读取数据，其中所有字段都是varchar类型，并将其保存到另一个具有类似字段但具有理想的正确数据类型的Oracle表中。这只能用java来完成。().register("toDate", new UDF1<String, java.sql.Date>() { public java.sql.Date call(T4CTTIoer.java</
浏览 5提问于2017-10-22得票数 0
3回答
我很熟悉使用模拟对象来帮助对Java类型进行单元测试，但是我发现这种不灵活的做法可能会导致测试类型变得冗长和繁琐，并导致大量重复。我发现在Scala
浏览 2提问于2009-07-18得票数 18
我正在开发一个Java应用程序，它在Flink 1.14上使用UDF。我使用PipelineOptions.JARS配置在应用程序代码中动态添加包含UDF类的jar文件，但是应用程序无法使用ClassNotFoundException从配置好的jar文件加载UDF类。如果使用“Flink run”和"-C“选项来更新类路径，通过flink CLI提交的应用程序jar工作得很好：
<FLINK_HOME
浏览 20提问于2021-12-15得票数 0
我使用java反射检查用scala编写的方法(我在scala中找不到合适的方法)，代码如下： // Get Method objectof "eval" method in udf var evalMethods: ListBuffer[Method] =new ListBuffe
浏览 1提问于2016-03-07得票数 0
回答已采纳
1回答
我在Scala和spark sql中工作，在那里我想调用UDF，它有多个参数。我不知道我的电话出了什么问题 udf是 private def parseJsonUdf: UserDefinedFunction = udf(parseJson _) df.withColumn(field, parseJsonUdf(col("data"), lit(field)))
} 可
浏览 17提问于2020-06-19得票数 0
您可以使用REPL对进行实时更新。更新:从理论上讲，似乎可以将Scala/Groovy</em
浏览 3提问于2012-08-28得票数 7
1回答
我试着在spark中使用UDF，注意到有三种不同的方法来声明UDF，从Scala语法的角度来看，这些声明中的每一种都意味着什么，一个UDF函数是如何以三种不同的方式访问的，从java开发人员的角度来看，// You could define UDF this way
//
浏览 1提问于2018-07-02得票数 0
输入-预期输出-有人能解释一下如何使用Java在
浏览 9提问于2021-09-22得票数 1
我想知道是否有可能将Spring MVC与Java之外的JVM语言一起使用，例如Groovy或Scala。或者Groovy只能在Grails上运行吗？另外，如果可能的话，这是人们经常尝试的东西，还是他们只是坚持传统使用的框架？
浏览 0提问于2009-12-24得票数 5
使用JDK附带的jconsole或jvisualvm工具在正在运行的JVM上执行垃圾收集非常简单，而且能够在有远程shell访问但没有X11访问或RMI访问的系统上使用jstat命令编写一些统计信息收集脚本是非常好的但是，我在JDK中找不到可以让我对运行中的进程执行垃圾收集的工具，我可以在没有显示环境的情况下从SSH会话调用这些垃圾收集。
JDK中真的没有这样的命令行工具，只有具有“执行GC”按钮的GUI工具吗?应用程序运行得很好，我只是想查看它使用了多少内存，而不是让它离线(不重新启动
浏览 5提问于2010-11-03得票数 1
回答已采纳
鉴于Groovy具有与Scala相同的大部分功能，我们是否可以编写Groovy程序来导入并在Groovy中进行科学计算。据说Apache Spark是用Scala编写的，spark为用Java或Scala编写客户端代码提供了完全相同的库。例如：org.apache.spark.mllib.linalg.Matrix mat =
new or
浏览 1提问于2015-11-06得票数 2
有几个人(、、)讨论过在PySpark应用程序中使用Scala UDF，通常是出于性能原因。相反，我感兴趣的是在Scala Spark项目中使用python UDF。我特别感兴趣的是使用sklearn (和)构建一个模型，然后有效地将其应用于Spark streaming作业中的记录。
浏览 0提问于2018-08-19得票数 11
在Python中，我很少有非常非常简单的函数，我想在Spark中作为UDF使用它们。从Python注册和使用它们似乎很容易。但是，我想在使用JavaSQLContext或SQLContext时使用Java/Scala中的它们。我注意到在spark 1.2.1中有函数，但我不清楚如何使用它，也不清楚是否应该.编辑:由于不再从事这方面的工作，我有兴趣知道如何在any Spark版本中进行此操作
浏览 7提问于2015-03-19得票数 9
因此，我想创建一个可以在Pyspark中使用的scala UDF。代码非常简单 (x: Seq[String], y: Seq[String]) => {for (a <- x; b <-y) yield (a,b)} 我已经创建了一个scala UDF来做这件事。它适用于Scala Spark。 我的问题是试图让这个在pyspark中可调用。import org.apache.spark.sql.api.java.
浏览 29提问于2020-10-09得票数 4
回答已采纳
org.apache.spark.sql.Row]我知道DatasetRow应该是Dataframe的同义词，但是我不知道如何避免这个错误function5>,DoubleType,Some(List(DoubleType, IntegerType, StringType, DoubleType, DoubleType)))
java.lang.ClassCastException: $anonfun$1 cannot be cast to scala<
浏览 0提问于2018-05-20得票数 3
回答已采纳
也许这很愚蠢，我是Microsoft / C#开发人员，以前从未真正使用过任何其他IDE /书面JAVA / SCALA。有很多临时函数示例，但我发现没有一个是针对非JAVA / SCALA开发人员的永久函数。{
//https://docs.oracle.com/javase/8/docs/api/java/sql/
浏览 0提问于2019-07-10得票数 3
回答已采纳
2回答
我需要从groovy执行PL/SQL块的帮助。此PL/SQL块调用返回1或0的函数。下面是我在groovy中所拥有的：String url = "jdbc:oracle:thin:@hostname: oracle.jdbc.driver.OracleDriver
java.lang.ClassNotFoundException:
浏览 2提问于2016-05-26得票数 0
1回答
我试图熟悉使用Scala的 (3.3)的-based计算。在能够使用GPU方面的主要争论似乎来自UDF的黑匣子性质。一个自动的解决方案是。但在有循环的情况下，它是行不通的。这将是很棒的，因为有时候很容易将所有列合并成一个WrappedArray列，使用concat_ws，UDF可以简单地转换成一个Array。done.The (我所指的情况如下)：
浏览 16提问于2022-07-27得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云直播
腾讯会议
腾讯云开发者
