user-defined-functions

    0热度

    2回答

    查找我做的火花项目和需要就如何解决的最佳方式如下问题: 我有一个数据帧(说MainDF),其中有上百万的记录。格式是这样的(name:String,value:Int)。下面的内容例如: Davi,130 Joel,20 Emma,500 我还有一个小文件,与4号线的记录,像这样(的className:字符串,minValue(最小值):诠释,包括maxValue:智力) 现在我需要创建通

    -1热度

    1回答

    我需要帮助定义一个函数,该函数在数据库中创建一个向量,其中对于每一行,函数查看该数据库中的另一列,在指定的数据库中搜索该值创建第二个数据库的一个子集,该数据库由所有匹配的行组成,并对该子集中的一个单独列进行求和,然后将该值返回到原始数据库中新列的相应行。 换句话说,我有一个看起来是这样的一个数据帧: ID <- c('a', 'b', 'c', 'd', 'e') M <- 20:39 df

    1热度

    2回答

    我有一个功能,通过 CREATE OR REPLACE FUNCTION public.div(dividend INTEGER, divisor INTEGER) RETURNS INTEGER LANGUAGE 'sql' IMMUTABLE LEAKPROOF STRICT SECURITY DEFINER PARALLE

    0热度

    1回答

    所以我运行下面的代码后得到的数据框恰好是我想要的。它与原始数据框相同,但所有包含纯数字数据的单元格都删除了所有的括号和斜线(括号在前面用负号替换)。 stringModifierIterator接受一个数据框并返回一个List [Column]。 List [Column]可以像命令dataframe.select(List [Column]:_ *)一样使用来创建一个新的数据帧。 不幸的是,列名

    1热度

    2回答

    我已经在Oracle中编写了存储过程。有什么办法可以在Hive或Spark中实现该存储过程的相同功能。 就像在Oracle存储过程中一样,我们有游标,我们也可以在其他过程中调用一个过程,并进行大量其他操作。 请提出建议,如果这可能在蜂巢或如果有其他方法。我在网上搜索,似乎Hive版本2提供了一个使用存储过程的选项。 但是旧版本的解决方案可能是什么? 我是Hive和Spark的新手,欢迎任何指导或建

    0热度

    2回答

    我正在尝试创建一个mysql函数来计算商店中前五位客户所花费的总额,但我一直收到以下语法错误。什么导致了错误? 错误: ERROR 1064 (42000): You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right synt

    0热度

    1回答

    当试图通过调用db2ReadLog的外部UDF获取DB2 LUW数据库上的事务日志信息时,返回SQL0487N(试图在SQL语句上执行)。使用与存储过程相同的共享库可以正常工作。 它需要成为一个UDF的原因是最终能够创建一个表值UDF,它将返回事务日志中的实际条目。 这里是C源为UDF确定初始LRI: #include <sqlca.h> #include <db2ApiDf.h> #incl

    0热度

    1回答

    我正在使用sql.js(编译通过emscripten从sqlite到js),当我在选择结果返回空行时运行UDF时,系统抱怨数字的参数不匹配(0,与我期望的结果数量相比)。 有没有办法简单地不调用UDF时,结果是空 ---我总是可以得到查询结果JS,检查基数,然后触发UDF,但我希望有一个解决方案,它包含在SQL中。 这是一个示例SELECT drawRect(x, y, width, height

    0热度

    1回答

    我对Scala很不习惯,所以我想要做的就是执行一个函数,该函数可以获取先前创建的列表的参数。然后我通过整个列表读取小写的每个元素来查找关键字。 最后,我计算了单词的数量并返回了该值。我的项目创建为Scala类,顺便说一下,在我的代码中,似乎小写字母不能读取下面的每个列表元素案件。 如果我把所有的代码移到一个可以工作的函数之外,但我不明白为什么在函数式的方法中它不会通过。 请家伙,给我一只手弄明白,

    0热度

    2回答

    我想创建一个用户定义的函数,以便在Excel工作表中使用。我的函数使用三个单元格范围作为输入,并应返回一个单一的值作为结果。如此,它在结构上与例如SUMPRODUCT函数,只有执行的数学是不同的。 这是我使用的代码: Function MyFunction(C(), V(), M()) As Double Application.Volatile (True) Dim i A