user-defined-functions

0熱度

1回答

我有一個39列的數據幀，每列都有不同的正常範圍。通過使用正常範圍，我想找出正常值，並把0否則把1. 這是我所做的，但我想爲39列做。 val test :(Double => Double) = (value: Double) => { if(value >= 45 && value <= 62) 0 else 1 } 但我不明白如何使用不同的值到每一列。用於離：

0熱度

3回答

使用WithColumn與外部功能

我有一個數據幀的數據與下面列 1）FILEFORMAT是以下所有列數據類型CSV 2）字符串 employeeid,pexpense,cexpense 現在我需要建立一個新的數據幀其中有一個名爲expense的新列，它是根據列pexpense,cexpense進行計算的。棘手的部分是計算算法是不是我創建了一個UDF功能，但它是一個外部函數，需要從一個Java庫，需要原始類型作爲參數輸入 -

2熱度

1回答

從mysql中的字符串獲取哈希標記

朋友，我想從字段中獲取哈希標籤。 select PREG_RLIKE("/[[:<:]]abcd[[:>:]]/","okok got it #abcd"); //output 1 但 select PREG_RLIKE("/[[:<:]]#abcd[[:>:]]/","okok got it #abcd"); //output 0 沒有得到爲什麼#沒有考慮請幫

0熱度

1回答

SQL server - 在創建之前檢查SP中是否存在對象

爲什麼在創建或更改時以下SP不會生成錯誤？我在數據庫'AdventureWorks2014'中不存在的以下SP中使用了一個標量函數[dbo.fn_General_GetCurrentTime()]。我很困惑它是否應該給出錯誤。有什麼辦法可以強制它檢查對象的存在嗎？ USE [AdventureWorks2014] GO SET ANSI_NULLS ON GO SET QUOTE

0熱度

1回答

Spark UDF不工作：如何指定要應用它的列？

比方說，我有我的DataFrame，給定的列名爲「X」。我想了解爲什麼第一個代碼不起作用，而第二個代碼卻不行。對我而言，它不會改變任何東西。，一方面，這不起作用： val dataDF = sqlContext .read .parquet(input_data) .select( "XXX", "YYY", "III" )

2熱度

2回答

R：在用戶定義函數中使用get和data.table

我正在學習如何編寫使用常見軟件包（如data.table和dplyr）的R函數。這個功能我寫的計算觀察的特定類別的百分比內的一些其他組（例如：與10-20mpg汽車的份額，被釋放在2015年那個），併產生一個表。這裏沒有它的功能： library(data.table) library(scales) #Create test dataframe and cut off points

0熱度

1回答

SQL Server：結合SELECT和相關的UDF結果

我未能谷歌這種情況下：我想插入新的行到（時隙）表，一些記錄（由WHERE子句選擇），並添加3列作爲用戶定義功能（計算空閒時隙日期，開始和結束時間）。即使UDF返回多於一行，也必須運行。基於微軟的有關使用UDF建議： SELECT ContactID, FirstName, LastName, JobTitle, ContactType FROM dbo.ufnGetContactInforma

0熱度

2回答

你能從Redshift的python UDF中返回多個值嗎？

我們使用JSONB偶爾存儲元素。這將作爲字符串傳遞給Redshift，然後使用UDF進行解析。對於審計報告，我想在一列中顯示JSON的一部分，而在另一列中顯示另一部分。我可以調用一個返回兩個值的UDF，而不是每行都調用兩個UDF，？作爲一個玩具的例子，考慮一個交易數據庫，其中每一行我們存儲客戶用來支付的方法。有些客戶可以支付多筆金額（例如，花費一張禮品卡，然後用現金支付差額），因此我們在該字段中

0熱度

1回答

由於輸入參數無效導致VBA用戶定義函數無法運行

我有一個Excel 2016 VBA UDF（用戶定義的函數），它看起來像這樣; Public Function AddUDF(Param1 As Single, Param2 As Single) 'Code implementation End Function 含量的細胞A1，A2被輸入到參數Param1，Param2。當單元格A1和A2包含數字時，UDF按預期正常運行。當

0熱度

1回答

Spark DataFrame UDF分區列

我想轉換一列。新列應該只包含原始列的一個分區。我定義下列UDF： def extract (index : Integer) = udf((v: Seq[Double]) => v.grouped(16).toSeq(index)) 在循環後用 myDF = myDF.withColumn("measurement_"+i,extract(i)($"vector")) 原始載體柱用它與創建