udf

    1熱度

    2回答

    我想將其他python/csv文件導入到我的python udf中以執行一些操作。 Like, 將表數據(以流的形式逐行輸入)與外部.csv行進行比較。 當我嘗試讀取.csv文件的數據,它給了我一個錯誤 IOError: File /home/abc/xyz/myfile.csv does not exist 雖然代碼工作得很好,當它被寫成正規的Python腳本(不喜歡UDF)

    0熱度

    1回答

    我想定義多個豬UDF。他們每個人都將提取不同部分的數據。在我的情況下,數據是具有包括許多嵌套JSON對象的複雜結構的JSON文檔。 問題是,現在我已經爲我需要的每個函數創建了不同的Eval類。這些類中的每一個都實現了exec()。 有沒有辦法把所有的功能放到同一個UDF類中,然後從豬中調用它們? 我UDF的一個實例: public class PigGetTimestamps extends Ev

    0熱度

    1回答

    我正在構建一個內部使用另一個udf的udf,但我在迭代變量中收到了錯誤「ByRef argument missing」,我有這個字符串「-60981- - :54044,-60981 - :54044,-60981 - :53835,-60981 - :53835,「我想刪除重複的項目,所以我想取回這個字符串」-60981 - :54044, 60981 - :53835,」這裏是第一UDF,這就

    5熱度

    1回答

    我創建了一個聚合函數,這在塞在其中工作的AQL工作: AGGREGATE filter2.check_teamId('123', 0, 1456499994597) ON analytics.tracking WHERE teamId = '123' 這將返回結果。 我然後嘗試使用相同的UDF中的NodeJS: var statement = { aggregationUDF: {

    0熱度

    1回答

    我有一個Python UDF,它將十六進制數據轉換爲字符串。當我嘗試在多個字段上調用UDF時,出現錯誤。這是我的Python UDF。腳本是hex_to_str.py #!/usr/bin/python @outputSchema("field:chararray") def hextoStr(field): if(field!=""): return field.decode

    0熱度

    1回答

    因此,我花了一段時間才弄清楚如何創建我的第一個UDF,但在修復它之後,我想我的下一個將是小菜一碟。不幸的是,情況並非如此。我正在拉一個字段(ORIG_CLAIM,float),我想對這個數字進行分類。這裏是我的代碼: CREATE FUNCTION [dbo].[fnOC_LEVEL](@ORIG_CLAIM float) RETURNS nvarchar(255) AS BEGIN

    0熱度

    1回答

    我正嘗試在teradata中創建一個Aggregate UDF函數。 作爲它的一部分即時嘗試decalre在中間存儲陣列。 當我試圖將它鏈接到teradata時,它不斷拋出下面的錯誤。 Executed as Single statement. Failed [7504 : HY000] in UDF/XSP/UDM DBC.IRR: SQLSTATE U0001: Elapsed time =

    0熱度

    1回答

    我在VBA中的UDF抱怨無效限定符,我不明白爲什麼。 預先感謝您的幫助。

    1熱度

    1回答

    我想在Spark SQL作業中使用DSL而不是純SQL,但是我無法獲得我的UDF工作。 sqlContext.udf.register("subdate",(dateTime: Long)=>dateTime.toString.dropRight(6)) 這不起作用 rdd1.toDF.join(rdd2.toDF).where("subdate(rdd1(date_time)) === su

    1熱度

    1回答

    我遇到過這種情況,需要我平均Vlookups數組的結果。我不知道如何用公式來實現這一點,並且似乎StackOverflow上的其他人也沒有任何想法。 所以我決定寫一個函數來爲我完成這個工作。不幸的是它返回「#VALUE!」錯誤,我不知道爲什麼!該功能在使用msgbox進行測試時工作正常。我有以下注釋我的代碼: Option Explicit Public Function AvgVlookup