udf

0热度

1回答

嘿家伙对于这个noob问题感到抱歉，我想学习mysql，但是我被困在创建udf。有人可以解释为什么这是语法错误和可能的修复程序是什么。感谢 create FUNCTION temtotalgrades (@p_Studid int, @p_year int) RETURNS int BEGIN return (SELECT CONCAT(fname, " ", lname, '\n', G

0热度

1回答

在Spark DataFrame中合并多个列[Java]

如何在单列（在新DataFrame中）中将DataFrame中的多个列（例如3）组合成一个Spark DenseVector？类似于这个thread，但在Java中，并在下面提到的一些调整。我尝试使用UDF这样的： private UDF3<Double, Double, Double, Row> toColumn = new UDF3<Double, Double, Double, Row>(

0热度

1回答

我怎样才能将一个类型的日期时间从Pig转换为python UDF

我的python UDF代码诞生了Pig的日期时间变量我试过它作为字符串对象，但它也给出了一个错误并将它当作DateTime对象也给了一个错误 from datetime import date @outputSchema("age_key:chararray") def agekeyed(born): today = date.today() return born

0热度

1回答

我们如何传递Cassandra“用户定义函数”中的常量值？

我们如何在Cassandra“用户定义函数”中传递一个常量值？我的UDF的签名： CREATE OR REPLACE FUNCTION spatial_keyspace.state_group_and_max(state map<text, int>, type text, pkey int, level int) CQL查询： select spatial_keyspace.group_an

3热度

2回答

在Spark SQL中，您如何注册和使用通用UDF？

在我的项目，我想实现ADD（+）函数，但我也许参数LongType，DoubleType，IntType。我使用sqlContext.udf.register("add",XXX)，但我不知道如何编写XXX，这是制作泛型函数。

1热度

1回答

Hive UDF处理Scala中的整数数组

我是scala中的新手，我需要编写用户定义的函数来处理Hive中的整数数组列（类型array<int>）。我已经试过： import org.apache.hadoop.hive.ql.exec.UDF class testUDF extends UDF { def evaluate(arr: Array[Int], txt: String): Boolean = {

0热度

1回答

火花阶定义输入参数的UDF

我在斯卡拉工作和火花我定义一个UDF，这里是 def udfcrpentcd = udf((CORP_ENT_CD:String)=>{ state_name match{ case "IL1" if state_name.contains("IL1")=> "IL1" case "OK1" if state_name.contains("OK1")=> "OK

0热度

2回答

通过shell脚本配置单元udf执行

我有一个Hive Udf在hive终端中运行良好，我想通过shell脚本执行它。在蜂巢终端，我能够执行下面的命令： use mashery_db; add jar hdfs://nameservice1/tmp/nextdata_aggregations/custom_jar/readerCheck.jar; add file hdfs://nameservice1/tmp/GeoLite2

1热度

2回答

BigQuery获取外部代码资源的元数据时出错

我在BigQuery中出现此错误“获取外部代码资源的元数据时出错”，并且它引用了驻留有GCS的UDF的文件。使用与代码相同的代码内联UDF的作品。但是，当我在GCS上引用它时，它会失败。这个错误是什么意思？而且，它为什么失败？

0热度

1回答

将使用累加器的最短猪脚本

我正在将一个Accumulator实现添加到Pig UDF，并且我想测试它。什么是将使用累加器的最短和最简单的Pig脚本？为了简单起见，假定它会加载一文件与Ñ整数，其中Ñ>pig.accumulative.batchsize，使得累加（）方法将被调用一次以上。 data = LOAD 'input' AS (val1:int); output = ... (code which uses