user-defined-functions

2熱度

2回答

如何在另一個數據幀上執行UDF時引用pyspark數據框？這是一個虛擬的例子。我創建了兩個數據幀scores和lastnames，並且在每個數據幀中存在兩個數據幀相同的列。在應用於scores的UDF中，我想過濾lastnames並返回在lastname中找到的字符串。 from pyspark import SparkContext from pyspark import SparkConf

3熱度

1回答

Spark/Scala使用多列上的相同函數重複調用withColumn（）

我目前有代碼，我通過多個.withColumn鏈重複將相同的過程應用於多個DataFrame列，並且希望創建一個函數簡化程序。 val newDF = oldDF .withColumn("cumA", sum("A").over(Window.partitionBy("ID").orderBy("time"))) .withColumn("cumB", sum("B").ov

0熱度

1回答

如何讓函數在（看似）嵌套環境（R）中搜索？

當我創建一個簡單的函數，它使用mget來調用在.GlobalEnv中分配的一個對象名稱，而另一個對象已在函數環境中分配時，我無法使mget函數在兩種環境中查找。例子： > abc <- 5 > > f1 <- function(x) { + bcd <- 6 + foo <- c('abc','bcd') + mget(foo) + } > > f1() Error: val

1熱度

1回答

Java源代碼編譯失敗 - Cassandra函數

0熱度

1回答

需要在用戶定義的函數列，並將其存儲在一個過程中

在Microsoft SQL Server Management Studio中我創建了一個用戶定義的函數基礎上誕生了用戶輸入的日期來計算僱員的年齡如下： USE [Northwind]; SET ANSI_NULLS ON GO SET QUOTED_IDENTIFIER ON GO CREATE FUNCTION udf_GetEmployeeAge_test2 ( @DateO

0熱度

1回答

在UDF中使用VBA代碼搜索時是否可以使用FindPrevious？

我正在嘗試使用VBA來處理基於「查找」函數的結果，因爲它比查詢結果的每個單元輪詢要快得多。我已經把它切回到它的基礎來重現錯誤，我仍然得到「對象變量或有塊變量未設置」的錯誤SearchRange.FindPrevious.Address（你必須停下來，得到的錯誤，UDF的剛剛退出，沒有返回在調試模式以外的錯誤）這裏的踢球，我試圖在一個表中使用UDF時得到錯誤，如：=testfind("3206-

-4熱度

1回答

excel vba UDF在公式中使用時執行3次

我想知道在用作公式時如何防止我的UDF執行3次。的Excel 2013（編譯：15.0.4859.1002）我建立了一個用戶定義函數必須驗證一組針對一個Excel的ListObject兩個值命名爲「table_Sequence」的。如果這些值存在，該函數將返回相應的字母。所以基本上，我試圖創建一個工具來幫助我們建立基於特定規則的SAP FLOC結構。其中一個級別是3位數字代碼，其中包含來自選

2熱度

1回答

斯卡拉：高階函數返回的套

我以下階高階函數工作的工會： def after(M: Set[Expression], n: String): Set[Set[Expression]] = { M.map((expr: Expression) => aft(expr,n)) } 功能後具有以下特徵： def aft(m: Expression, n: String): Set[Expression] 類型Express

0熱度

1回答

Spark：加入UDF或map函數

我必須編寫一個複雜的UDF，其中我必須使用不同的表進行連接，並返回匹配數。實際使用情況要複雜得多，但我已將這種情況簡化爲最小可重現代碼。這是UDF代碼。 def predict_id(date,zip): filtered_ids = contest_savm.where((F.col('postal_code')==zip) & (F.col('start_date')>=date))

0熱度

2回答

非列參數的火花udf

我想將一個變量而不是一列傳遞給火花中的UDF。地圖是以下格式的 Spark dataframe to nested map val joinUDF = udf((replacementLookup: Map[String, Double], newValue: String) => { replacementLookup.get(newValue) match { case