user-defined-functions

3熱度

1回答

我想修改所有使用'never expire'TTL（客戶端爲-1）意外設置的記錄的TTL。我會怎麼做？

1熱度

1回答

我在BigQuery中有一列包含URL查詢字符串，例如a=1&c=1。我想在我的查詢中引用其中的一些，例如。用類似WHERE querystring.c = 1的東西過濾。我的計劃是將查詢字符串轉換爲JSON，然後使用JSON_EXTRACT。我想我可以編寫一個UDF來將查詢字符串轉換爲JSON，但是我仍然無法解決將node.js querystring package導入到我的UDF中的問題。

0熱度

2回答

在Apache Spark中爲每行迭代添加作用域變量

我正在將多個html文件讀入Spark中的數據框。我使用一個自定義轉換的HTML元素列在數據幀UDF val dataset = spark .sparkContext .wholeTextFiles(inputPath) .toDF("filepath", "filecontent") .withColumn("biz_name", parseDocVa

1熱度

3回答

刪除數組中的重複[字符串]

我有一個dataframe列array的string如下。（Key，value）對 ColA [(1,2),(1,3),(1,4),(2,3)] 我必須按最小值刪除重複鍵並獲得結果。不想爆炸並做到這一點。密鑰應該是唯一的，密鑰是基於最小值挑選的。（1,2），（1,3），（1,4）輸出中輸出（1,2）應該是：可樂 [（1,2），（2,3）] 我創建像 Val removeDup =

1熱度

1回答

SQL Server表值函數基於<a href="https://docs.microsoft.com/en-us/azure/app-service-web/web-sites-dotnet-entity-framework-row-level-security" rel="nofollow noreferrer" title="Row level security">Row level security</a>我創建了一個表值函數執行的代碼

： CREATE FUNCTION Security.userAccessPredicate(@ValueId int) RETURNS TABLE WITH SCHEMABINDING AS RETURN ( SELECT 1 AS accessResult WHERE @ValueId = ( SELECT Value FROM db

0熱度

1回答

如何轉換字符串的火花數據幀陣列中的蟒蛇

到矢量我有一個表test_tbl： +-----------------+--------------+--------------+--+ | test_tbl.label | test_tbl.f1 | test_tbl.f2 | +-----------------+--------------+--------------+--+ | 0 | a | b | | 1

1熱度

4回答

傳遞UDF的方法或

類我有一個UDF說 val testUDF = udf{s: string=>s.toUpperCase} 我想在一個單獨的方法來創建這個UDF或可能是別的東西像一個實現類，並通過它，它使用它的另一個類。可能嗎？說假設我有一個A級 class A(df: DataFrame) { def testMethod(): DataFrame = { val demo=df.

1熱度

1回答

爲什麼我們不會在表值函數上使用INNER JOIN？

在線搜索後，我一直無法找到任何暗示你可以或應該使用INNER JOIN和表值函數的東西，我很好奇，爲什麼？例如，SSRS報告開發人員在報告中使用了一個非常常見的TVF用於多值參數，因此他們可以將結果解析爲表格。 CREATE FUNCTION [dbo].[ParmSplit] ( @List nvarchar(MAX), @SplitOn nchar(1)) RETURNS

0熱度

2回答

將用戶定義在for循環中的列表中

將用戶定義的函數存儲在for循環中時，存在將用戶定義的函數存儲在R列表中的問題。我必須根據一些參數定義一些特定於細分的函數，所以我創建函數並將它們放在循環中使用for-loop循環的列表中。問題是我在結果列表中的所有地方都有相同的功能。的代碼看起來是這樣的： n <- 100 segmenty <- 1:n segment_functions <- list() for (i in se

0熱度

1回答

如何在配置單元的python UDF中使用外部庫？

我想要使用一個Python UDF來轉換一個配置單元表（hdfs專題實例），爲此我需要一個外部庫「user-agents」。我沒有使用外部庫的udf工作正常。但是，當我想要使用它時，我無法使其工作。我嘗試使用下面給出的代碼本身安裝庫。 import sys import subprocess import pip import os sys.stdout = open(os.dev