mysql UDF返回INT而不是STRING
MySQL UDF（User-Defined Function）是用户自定义函数的缩写，它允许开发人员根据自己的需求扩展MySQL的功能。UDF可以用C/C++编写，并通过动态链接库（DLL）的形式加载到MySQL中。
MySQL UDF返回INT而不是STRING的情况可能是由于以下原因之一：
- 数据类型匹配：UDF函数的返回值类型在定义时可能被错误地指定为INT而不是STRING。在创建UDF函数时，需要确保返回值类型与实际返回的数据类型匹配。
- 数据转换：UDF函数内部可能存在数据转换的逻辑，将本应返回STRING类型的数据转换为INT类型。这可能是由于开发人员的意图或者错误导致的。
- 编程错误：UDF函数的实现代码中可能存在编程错误，导致返回的数据类型与预期不符。这可能需要对UDF函数的代码进行调试和修复。
无论是哪种情况，都需要仔细检查UDF函数的定义和实现代码，确保返回值类型正确，并进行必要的调试和修复。
对于MySQL UDF的应用场景，它可以用于扩展MySQL的功能，实现一些特定的计算、数据处理或者其他定制化需求。例如，可以使用UDF函数实现自定义的数学函数、字符串处理函数、日期函数等。UDF函数可以在查询语句中直接调用，与内置函数一样使用。
腾讯云提供了MySQL数据库服务，您可以在腾讯云的云数据库MySQL产品中使用UDF函数。具体的产品介绍和使用方法可以参考腾讯云的官方文档：腾讯云云数据库MySQL产品介绍。
请注意，本回答中没有提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等流行的云计算品牌商，以符合问题要求。
相关·内容
我刚开始使用程序，似乎不能让我的程序正常工作。我正在使用WAMPP v5.1.36，并使用MySQL服务器上的MySQL控制台输入代码。如果我去(重新)创建这个过程。我得到错误#1304 (42000)。
mysql> DELIMITER //
mysql>
mysql> CREATE PROCEDURE modx.getCRID (IN x VARCHAR(255),OUT y INT)
-> BEGIN
-> DECLARE y INT;
-> SELECT id INTO y
-
浏览 1提问于2010-08-04得票数 5
回答已采纳
2回答
有关出现问题的系统的信息：
操作系统:Debian8.1 64位- MySQL版本: 5.5.44 - GCC: 4.9.2
我正在创建一个简单的UDF函数，它将返回字符串Hello。问题是，它将返回Hello，连接到它，有一个长的随机二进制字符串，具有可变大小的随机数据，这将从执行到执行。
hello_world.c
#ifdef STANDARD
/* STANDARD is defined,
don't use any mysql functions */
#include <stdlib.h>
#include <stdio.h>
#include &
浏览 6提问于2015-09-04得票数 0
回答已采纳
1回答
我想在ASP.NET MVC 4 Razor中显示用户定义的函数中的信息。数据库中的函数如下所示：
CREATE FUNCTION dbo.udf_GetReportsByController(@controller_account VARCHAR(128))
RETURNS @retReports table (
ID INTEGER IDENTITY PRIMARY KEY,
ProviderID VARCHAR(50) NOT NULL ,
VertragID INTEGER NOT NULL,
Leistungszeitraum_von DATE N
浏览 2提问于2014-01-26得票数 0
回答已采纳
我使用Spark2.4已经有一段时间了，最近几天我刚刚开始使用Spark3.0。在切换到Spark3.0运行udf((x: Int) => x, IntegerType)后，我得到了这个错误
Caused by: org.apache.spark.sql.AnalysisException: You're using untyped Scala UDF, which does not have the input type information. Spark may blindly pass null to the Scala closure with primitive-ty
浏览 9提问于2020-12-03得票数 6
回答已采纳
我将数据从数据库加载到Spark，名为DF，然后必须从其ID具有特殊条件的Dataframe中提取一些记录。所以，我定义了这个函数：
def hash_id(id:String): Int = {
val two_char = id.takeRight(2).toInt
val hash_result = two_char % 4
return hash_result
}
然后，我在这个查询中使用这个函数：
DF.filter(hash_id("ID")===3)
但我收到了这个错误：
value === is not a member of Int
DF有ID列。
请您指
浏览 2提问于2021-09-21得票数 0
回答已采纳
因此，我创建了一个UDF，它接受两个字符串并将它们连接起来。
我的UDF: // concat_kv.c
#include <my_global.h>
#include <my_sys.h>
#include <mysql.h>
#include <ctype.h>
#include <string.h>
#include <stdlib.h>
typedef unsigned long ulong;
my_bool concat_kv_init(UDF_INIT *initid, UDF_ARGS *args, ch
浏览 1提问于2019-05-07得票数 5
回答已采纳
2回答
我正在尝试创建一个用于MySQL的UDF。我用gcc编写了这个函数，它工作正常。然后，我将.so文件移动到插件目录中，并输入到MySQL服务器。我试图使用以下代码创建函数：
CREATE FUNCTION mynew_udf RETURNS INT SONAME 'mynew_udf.so';
但是，服务器没有按应有的方式创建函数，而是输出以下错误：
错误1127 (HY000)：在库中找不到符号'mynew_udf‘
有人知道这个问题的解决方案吗?或者为什么会发生这个错误？谢谢。
浏览 5提问于2011-06-29得票数 3
我正在尝试创建一个MySQL UDF getFile()，它应该从磁盘上的某个目录返回文本文件的内容。问题是，调用会工作一两次，但在第二次或第三次调用UDF时，MySQL服务器就会崩溃。
我不能通过直接从mysql控制台调用getFile()来重现这个错误，在这里它似乎工作得很好-它似乎只有在我从存储过程中调用UDF时才会发生。当我只调用较小的(2.5k) "session“文件而忽略较大的"mailConfirmation”(45k)和"mailProtocol“(88k)文件时，错误也会消失，因此它似乎与文件大小有关。
MySQL版本: 5.1.49-3
操作系统:
浏览 1提问于2013-01-11得票数 1
1回答
雪花查询不返回时区信息。
、、、
使用雪花JDBC和Ruby驱动程序查询时，带有时区元素的时间戳值不会正确返回。
当数据类型为雪花中的timestamp_ltz、timestamp_ntz、timestamp_tz类型时，我们是否可以添加额外的库来获取结果集中的区域信息。
import java.sql.*;
import java.util.Properties;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import net.snowflake.client.core.QueryStatus;
imp
浏览 0提问于2021-02-24得票数 1
我想将我的features(类型:ml.linalg的稀疏向量)分解为每个特性的索引和值，因此我执行以下操作：
def zipKeyValue(vec:linalg.Vector) : Array[(Int,Double)] = {
val indice:Array[Int] = vec.toSparse.indices;
val value:Array[Double] = vec.toSparse.values;
indice.zip(value)
}
val udf1 = udf( zipKeyValue _)
val df1 = df.withColumn("feat
浏览 1提问于2018-08-21得票数 1
回答已采纳
这是我的两个工作表的一个小例子。
原始页：
如您所见，此工作表有两个单元格等待在稍后阶段重新计算。(即带有红色#Eval标记的细胞)
结果单
在以上结果表中，我们分别得到了两个结果:草莓和桃子。这两个结果是为两个#Eval单元准备的，需要替换#Eval标记。
注意#Eval实际上是由UDF返回的，表示需要重新计算这个单元格。重新计算将通过单击按钮或其他方式手动启动。
还请注意，该位置映射到两个工作表--如果#Eval位于单元格A3中，则结果也将显示在结果表中的单元格A3中。
所以，我的主要目标是用相应的结果替换#Eval单元。但是我在将结果传递到我的UDF时遇到了麻烦--我
浏览 1提问于2011-09-22得票数 1
回答已采纳
我一直试图在MySQL5.6中添加用户定义的函数，它执行一个简单的任务--即查找column1的最大值并返回另一列的值，即column2，它对应于column1的最大值。
我知道在这个概念中没有几个注意事项，比如如果column1的最大值为2，那么应该返回哪个对应的column2值。但这些事情不是我现在主要关注的领域。
我已经编写了函数程序，其中column1和column2都是双倍的。它在跑。但是，当我尝试使用column1是double，而column2是类型为string.The的情况时，我面临的问题是它会给出错误ERROR 1127 (HY000): Can't find sy
浏览 4提问于2016-11-11得票数 2
回答已采纳
我有张像下面这样的桌子，
+----------+-----+
| tmp|index|
+----------+-----+
| [user1,0]| 0|
| [user1,3]| 1|
|[user1,15]| 2|
我想要分裂的tmp列和两列。tmp是字符串类型，索引是Int。
我编写的udf如下所示。
val getUser_id = udf( ( s : (String, Int)) => {
s._1
})
newSession.withColumn( "user_id", getUser_id($"tmp"
浏览 2提问于2017-08-19得票数 2
回答已采纳
我不明白为什么使用AdvanceFilter的UDF在调试模式(F8)中工作，但在正常模式下执行时提供了错误9- Subscript超出范围。好像执行得太快了(？)在运行时模式下，而不是一步一步地。
为了获得更高的精度，我的UDF代码示例(gAitemCT是用户定义的类型)：
Public Function fG_PasteCTLinesOnSheetTmpFilteredDataset( _
ByRef gL_CTLine_P As gAitemCT, ByRef intNbOcc As Integer) As String
Dim sRet As String, sMsg As S
浏览 1提问于2017-04-13得票数 0
回答已采纳
2回答
在用MySQL编写UDF时，我不得不从c调用一个c++函数，该函数应该返回char *。我试过的是：
encrypt.cpp
string encrypt(string Data)
{
...
//some encryption logic
...
return encryptStr; //encryptStr is string
}
为了从c #调用上面的函数，我在与以下文件相同的文件中使用extern c：
extern "C" char * c_encrypt(char *bar)
{
std::string str = encrypt(
浏览 0提问于2018-12-17得票数 0
回答已采纳
为了连接到MySql数据库并检索值，我一直在使用Excel中的ADODB连接。
我的代码的实质如下：
Public Function ODPH(B0 As Range, sqlstr As Variant)
Dim oconn As ADODB.Connection
Dim rs As ADODB.Recordset
On Error GoTo error_handler
'Connect to MySql. Assign default values if connection string is missing!
ipDriver = "{MySQL ODB
浏览 3提问于2014-06-30得票数 1
我正在编写一个Excel函数，我希望它可以选择地将第二个结果写入一个
Public Function foo(A As String, B As String, C As String, Optional optionalRes As Range = Nothing)
...
If not optionalRes is Nothing then
optionalRes.Value="Result!"
End If
End Function
不幸的是，这不起作用我得到这个错误:错误1004 (应用程序定义的或对象定义的错误)在foo的模块fooBar。
我想做的至少
浏览 1提问于2014-05-27得票数 1
回答已采纳
2回答
我正在尝试为配置单元创建一些自定义函数，它为我提供了比已经提供的split()函数更多的功能。
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
public class LowerCase extends UDF {
public Text evaluate(final Text text) {
return new Text(stemWord(text.toString()));
}
/**
* Stems words to normal form.
浏览 3提问于2013-06-17得票数 2
回答已采纳
我试图为MySQL (一个可由MySQL执行的C函数)创建一个UDF函数，但是我遇到了各种各样的问题。我就直接给你代码吧。我有一个levenshtein.c文件，其中包含以下声明和相应的实现：
my_bool sql_levenshtein_init(UDF_INIT *initid, UDF_ARGS *args, char *message);
void sql_levenshtein_deinit(UDF_INIT *initid);
longlong sql_levenshtein(UDF_INIT *initid, UDF_ARGS *args, char
浏览 0提问于2012-03-14得票数 4
我在牢房里有这样的公式：
=GetData("Channel_01","Chicago")
它执行以下代码：
Public Function GetData(ChannelCode As String, Key As String) As String
Dim sql As String
Dim cmd As New ADODB.Command
Dim outputTo As Range
Set outputTo = Application.Caller
sql = "select * from Chann
浏览 3提问于2010-12-07得票数 2
回答已采纳
我正在尝试为MySQL创建最基本的用户定义函数。
#include <mysql.h>
extern "C" {
my_bool foo_init(UDF_INIT *initid, UDF_ARGS *args, char *message);
char *foo(UDF_INIT *initid, UDF_ARGS *args, char *is_null, char *error);
}
my_bool foo_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
retur
浏览 2提问于2017-03-18得票数 1
4回答
该程序由3个文件组成：demo.c、mylib.c和mylib.h。代码有很大的注释。
示范c：
/***********************************************************************
*
* This is a program that prompts the user for an input string using a
* custom input function.
*
***********************************************************************/
#
浏览 0提问于2016-05-22得票数 7
回答已采纳
2回答
我试图通过Hive UDF通过collect_set将一个数组传递给一个
SELECT ..., collect_set(...) FROM ...;
我的Hive UDF想要接受这个数组并将每个数组元素的第一个字母附加到输出字符串中：
public class MyUDF extends UDF {
public String evaluate(String[] array) {
String output = "";
// Check for valid argument
if (array == null) return output;
浏览 1提问于2015-05-25得票数 1
3回答
我使用了以下查询：
select id from foo order by id DESC limit 1
返回使用的最后一个id。
在我的应用程序中，如果它不是零的话，我可以添加一些东西。一切都很顺利。但我决定在sql中而不是在C#代码中这样做。但当我这么做的时候
SELECT IF(id = 0, 0, id + 1) as id from foo order by id DESC limit 1
但是我得到了一个System.InvalidCastException错误，令我惊讶的是，下面代码中打印的数据类型是int64。但它改变了吗？
以下是c#代码：
public int GetL
浏览 3提问于2015-07-02得票数 0
回答已采纳
以下是我的示例代码。我期望从UDF返回类型为decimal(16,4)，但它是decimal(38,18)。 有没有更好的解决方案？ 我不期望得到“cast(价格表示为decimal(16,4))”的答案，因为除了强制转换之外，我的UDF中还有其他一些业务逻辑。 提前谢谢。 import scala.util.Try
import org.apache.spark.sql.functions.udf
import org.apache.spark.sql.types.Decimal
val spark = SparkSession.builder().master("local[*]
浏览 271提问于2020-04-08得票数 1
回答已采纳
在MySQL中可以获取XML中的节点名吗？
我在存储过程中使用以下内容来迭代XML的节点，但是这样我只能获得值，而不是节点名称：
DECLARE i INT DEFAULT 1;
DECLARE nrows INT DEFAULT 1;
DECLARE rownum INT DEFAULT 1;
DECLARE vTag VARCHAR(100) DEFAULT '';
DECLARE returnvalue TEXT DEFAULT '';
DECLARE paramXML TEXT DEFAULT '<fields><a>1
浏览 1提问于2014-01-10得票数 0
当执行时，触发器抛出下面的错误。请帮帮忙
DELIMITER |
CREATE TRIGGER `Problem_created` AFTER UPDATE ON `WorkOrder_Fields` FOR EACH ROW
BEGIN
DECLARE problem_time_stamp int;
IF NEW.UDF_CHAR37 ='Problem' AND OLD.UDF_CHAR37='Incident'
THEN
SET problem_time_stamp = (SELECT UNIX_TIM
浏览 2提问于2015-01-26得票数 0
1回答
我试图在Go和cgo一起编写一个MySQL UDF，其中我有一个基本的功能，但是有一些小的零碎我无法弄清楚，因为我不知道C变量中有哪些是Go的。
这是我用C编写的一个示例，它强制一个MySQL参数的类型为int。
my_bool unhex_sha3_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
if (args->arg_count != 2) {
strcpy(message, "`unhex_sha3`() requires 2 parameters: the message part
浏览 3提问于2018-07-20得票数 1
回答已采纳
这可以将字符串123456输出为：
1
2
3
4
5
6
代码：
declare @string varchar(20)
declare @index int
declare @len int
declare @char char(1)
set @string = '123456'
set @index = 1
set @len= LEN(@string)
WHILE @index<= @len
BEGIN
set @char = SUBSTRING(@string, @index, 1)
print @char
SET @index= @index+ 1
END
浏览 0提问于2014-02-24得票数 0
回答已采纳
2回答
我有一个带有col_a和col_b的数据文件，在我收到的拼花文件中两者都被写成"String“。col_b可以是int或字符串，我希望筛选出col_b不是int的所有行。
Input:
col_A col_b
1 "abc"
2 "3"
3 "xyz"
Output:
col_a col_b
2 3
我知道我需要打字，但我不知道该怎么做。
浏览 1提问于2018-04-23得票数 1
回答已采纳
1回答
我正在用雪花编写用户定义的函数，并在函数中进行一些选择。如果select返回NULL，我需要返回0。
在下面的示例中，如果tableA没有可用的rid，则函数将返回NULL，但我需要函数返回0而不是NULL。
另外，如何在雪花中声明变量的内部函数？
例：
CREATE OR REPLACE FUNCTION A(ID int)
RETURNS float(53)
AS
$$
SELECT rid from tableA;
$$
;
浏览 8提问于2022-01-19得票数 1
回答已采纳
1回答
我尝试用C为linux上的firebird创建一个UDF文件。函数是从字符串中获取左字符。
我使用以下代码：
#include <stdlib.h>
#include<string.h>
#include <stdio.h>
char EXPORT *substr(const char *str, int start, int n);
char EXPORT *leftstr(const char *nama, int jumlah);
char* substr(const char *str, int start, int n)
{
char *pn
浏览 2提问于2014-03-18得票数 2
我正在为MySQL运行一个用户定义的函数插件。程序可以正常工作，除非您执行系统调用。我需要做一个系统调用来调用一个Python3脚本！使用system()或execl()，所有的系统调用都会返回-1并失败。
有人知道如何使我的C库MySQL UDF插件能够执行命令吗？我们完全被困在这里了，谢谢！
下面是我遇到问题的C代码：
# Written in C Language
#include <string.h>
#include <stdio.h>
#include <mysql.h>
bool udf_callpython_init
浏览 4提问于2021-12-21得票数 0
如果我有一个UDF返回一个包含数千行的表，但我只想要该行集中的特定行，SQL Server是否能够有效地处理此问题？
DECLARE @pID int; --...
SELECT * FROM dbo.MyTableUDF(@pID)
WHERE SomeColumn BETWEEN 1 AND 2 OR SomeOtherColumn LIKE 'this_pattern&'
查询优化器在多大程度上能够对这类查询进行推理？
如果表值UDF不带参数，它们与传统视图有什么不同？
有什么需要我知道的吗？
浏览 1提问于2010-04-29得票数 0
1回答
使用Scala类作为UDF
、、、、
当使用Apache时，我试图将一些计算从Python卸载到Scala。我想使用Java的类接口来使用持久变量，如这样(这是一个基于我更复杂的用例的无意义的MWE )：
package mwe
import org.apache.spark.sql.api.java.UDF1
class SomeFun extends UDF1[Int, Int] {
private var prop: Int = 0
override def call(input: Int): Int = {
if (prop == 0) {
prop = input
}
p
浏览 0提问于2018-04-03得票数 3
回答已采纳
4回答
我已经在配置单元中创建了一个udf，以便在配置单元中添加自动增量列。
import org.apache.hadoop.hive.ql.exec.UDF;
public class AutoIncrUdf extends UDF {
int Value;
public int evaluate() {
Value++;
return Value;
}
}
我在我的表上使用时创建了一个临时函数temp，如下所示
Select temp() from table1;
它将所有行都指定为：
1
1
1
1
诸若此类。但我希望
浏览 0提问于2013-02-04得票数 0
1回答
我有一个MySQL UDF，它返回无符号长值。当我在MySQL中调用此函数并将数据保存到数据库中时，MySQL返回警告：
"BIGINT无符号值超出范围“。
如何在数据库中保存大的无符号长号？
MySQL版本: 5.5.43
操作系统: Ubuntu 14.04
请帮帮忙。
浏览 1提问于2015-06-08得票数 2
回答已采纳
我有一个df：
joined.printSchema
root
|-- cc_num: long (nullable = true)
|-- lat: double (nullable = true)
|-- long: double (nullable = true)
|-- merch_lat: double (nullable = true)
|-- merch_long: double (nullable = true)
我有一个udf：
def getDistance (lat1:Double, lon1:Double, lat2:Double, lon2:Double)
浏览 1提问于2019-03-13得票数 1
回答已采纳
1回答
我想在full_outer_join的基础上加入两个数据格式，并试图在联合结果集中添加一个新列，它告诉我匹配的记录、仅来自左侧数据的不匹配记录和来自右数据from的不匹配记录。
这是我的星星之火代码：
val creditLoc ="/data/accounts/credits/year=2016/month=06/day=02"
val debitLoc = "/data/accounts/debits/year=2016/month=06/day=02"
val creditDF = sqlContext.read.avro(creditLoc)
val d
浏览 2提问于2017-09-27得票数 1
回答已采纳
我在MySQL 5.7.25表中存储了唯一的标识符，它们是字符，包含点和斜杠。 现在我需要在没有这些字符的情况下搜索它们。 例如:已知字符串: 25518000 表内: 255.18.000 似乎只有在MySQL > 8.x中才实现了preg_replace。 如何在忽略某些字符的情况下搜索给定的字符串？ 如下所示： SELECT * FROM `cat_attr` WHERE `attr_de` REGEXP '\\.' = 25518000
浏览 21提问于2019-04-30得票数 1
回答已采纳
我想使用一个结构体作为UDF的返回类型，然后从结果中提取单独的字段。这是我尝试使用的hello world版本的用例：
create temp function udf_struct_test(orig string)
returns struct<original int64, plus1 int64>
language js as """
var original = parseInt(orig);
var plus1 = 1 + original;
return { original, plus1 };
""";
with
浏览 0提问于2018-10-05得票数 1
2回答
星火UDF中的类型错配
、、、
我创建了以下UDF，只获取1部分十进制值。
def udf_cleansing(col1 : Double) = udf((col1 : Double) => {
val col2 : String = f"$col1%.5f"
if(col2.trim == "" || col2 == null ) 0.toString else col2.substring(0,col2.indexOf("."))}
)
但是，在使用命令调用此函数时，如
df_aud.select(udf_cleansing(df_aud("HASH_TTL&
浏览 0提问于2018-02-05得票数 4
回答已采纳
1回答
编辑：我重写了这个问题，因为我没有得到答案，我目前正试图缩小问题的范围。
我正在尝试创建一个，检查服务器端是否存在一个文件。此函数调用“打开/关闭”。即使文件是可读的，它也不起作用。
我把这个函数的代码放在下面：
#include <mysql.h>
#include <string.h>
#include <errno.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include
浏览 1提问于2010-05-26得票数 2
回答已采纳
def nameFilter= (name:String):String =>{
if(name.startsWith("A")) name
}
val register= udf(nameFilter)
concatDf.select(register(col("Region"))).show()
})
concatDf.select(ageFilter(col("Region"))).show()
我有concatDf，其中有一个名为Region的列，我希望以"A“开头的区域应该出现。
不，我写了以下的udf。但例外
浏览 2提问于2022-08-14得票数 0
回答已采纳
在中，我创建了一个用户定义函数，根据用户输入的出生日期计算员工的年龄，如下所示：
USE [Northwind];
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE FUNCTION udf_GetEmployeeAge_test2
(
@DateOfBirth datetime
)
RETURNS int
AS
BEGIN
DECLARE @Age int
SELECT @Age = DATEDIFF(DAY, @DateOfBirth, GETDATE())
RETURN @Age
END
我正在使用流行的示例Northwi
浏览 0提问于2017-01-22得票数 0
回答已采纳
MySQL文档()中有一条语句困扰着我：
“UDF包含成为正在运行的服务器的一部分的代码，因此当您编写UDF时，您将受到任何和所有其他应用于编写服务器代码的约束的约束。例如，如果您试图使用来自libstdc++库__的函数，您可能会遇到问题。”
如果使用C++标准库函数来编写UDF，为什么会出现问题？
这是否意味着我注定要使用普通的老C来编写我的UDF ?？(请说否)
浏览 1提问于2009-04-08得票数 2
回答已采纳
1回答
我想声明一个返回2个1维数组或1个2维数组的udf (两个都是很好的例子)。我知道这适用于1D：
@udf("array<int>")
然而，我已经尝试了许多变体，比如下面这些，但都没有成功：
@udf("array<int>,array<int>")
@udf("array<int>","array<int>")
@udf("array<int,int>")
etc.
浏览 4提问于2019-01-30得票数 1
基于某些关键字聚合数据集，但通过固定数量限制聚合列表。
附加了用于创建数据集的代码。需要帮助来实现类似grouped()与list的工作方式的机制。
case class AggrBook(
city: String,
state:String,
books:List[Int]
)
case class Bookings(bookingId: Int,
userId:String,
city
浏览 4提问于2021-10-18得票数 1
1回答
我正在尝试创建一个用户定义的函数，它接受数组的累加和，并将值与另一列进行比较。下面是一个可重复的例子：
from pyspark.sql.session import SparkSession
# instantiate Spark
spark = SparkSession.builder.getOrCreate()
# make some test data
columns = ['loc', 'id', 'date', 'x', 'y']
vals = [
('a', 'b&
浏览 5提问于2019-10-18得票数 3
回答已采纳
我有个案课
case class MyCaseClass(City : String, Extras : Map[String, String])
以及返回scala.collection.immutable.Map的用户定义函数
def extrasUdf = spark.udf.register(
"extras_udf",
(age : Int, name : String) => Map("age" -> age.toString, "name" -> name)
)
但这也有例外：
import spar
浏览 2提问于2016-07-21得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
