user-defined-functions

0熱度

1回答

我有大量文字的Python程序我要對齊和.format顯得凌亂，所以我計劃上的print像這樣結束使用.center(shutil.get_terminal_size().columns)： import shutil print("Hello world!".center(shutil.get_terminal_size().columns)) ，應該在我的控制檯返回中心，它是。但是，如

1熱度

1回答

SQL遞歸udf總是返回null

Create Table Employees ( Employee varchar(10), Manager varchar(10) ); Insert into Employees values ('Charlie',null), ('Peter','James'), ('Elai',null), ('Graham','Emanuel'), ('Amanda

1熱度

1回答

檢查一列是否具有正確的十進制數

我有一個數據幀（input_dataframe），它看起來像如下： id test_column 1 0.25 2 1.1 3 12 4 test 5 1.3334 6 .11 我想增加一列結果，裏面放值如果test_column具有十進制值和如果test_column具有任何其他值。數據類型test_column是字符串。以下是預期輸出： id tes

1熱度

1回答

星火2.1 UDF沒有得到註冊星火罐

我使用星火2.1 CDH集羣使用Scala版本2.11.8 我創建了一個UDF中的我的方法之一。當我在Spark Shell Repl中執行該方法時，它工作得非常好。但是，當使用Spark提交命令從Spark Jar調用方法時，相同的UDF無法註冊。下面是build.sbt內容： name := "newtest" version := "0.0.2" scalaVersion :=

0熱度

1回答

UDF不工作火花階

這是怎麼我在火花數據幀使用UDF .. val sqlContext = new org.apache.spark.sql.SQLContext(sc) import sqlContext.implicits._ import org.apache.spark.{ SparkConf, SparkContext } import java.sql.{Date, Ti

0熱度

1回答

警告是什麼意思：條件長度> 1，只有第一個元素將被使用

我收到警告：「條件長度大於1，只有第一個元素將被使用」，當我嘗試使用下面的函數fixED： > fixED function(x) { if(nchar(x) == 5) { return(x) } else if(nchar(x) == 3) { return(gsub('^(.{2})(.*)$', '\\100\\2', x))

0熱度

2回答

慢UDF的SQL替代

具有兩個UDT參數的查詢需要0.3秒，但是當封裝在內聯表值函數中時，需要3.5+秒。我讀過（Why is a UDF so much slower than a subquery?），但我正在努力修復/重寫。每低於@ JasonALong的反饋，的SELECT語句中0.3秒完成執行計劃：https://www.brentozar.com/pastetheplan/?id=HJnrqC53Z（

2熱度

1回答

用戶定義的函數在Pycharm中返回不正確的值，但不是IDLE

我對編程非常陌生，並且遇到了一些我無法想象的東西！我有一個用戶定義的函數，它應該計算百分比： def test_score(num_correct, total): temp_value = num_correct/total return temp_value*100 a = 12 b = 20 print(test_score(a, b)) 通過我的計算程序應

3熱度

1回答

是否可以在Scala中打印函數的定義

我想知道我們是否可以在Scala中打印函數的定義。一個函數被視爲Scala中的一個對象。例如：階> VAL splitFunction =（值：字符串）=> {value.split（」「）} splitFunction: String => Array[String] = <function1> 以上，Scala的交互式shell表示splitFunction具有輸入參數字符串，它返回字

1熱度

1回答

在scala命令行中讀取文本文件行

我想通過scala命令行讀取文本文件。代碼編譯正確，但由於文件未找到錯誤而導致執行失敗。 import scala.io.Source object Mainclass extends App { val filename = "filo.txt" for(line <- Source.fromFile(filename).getLines) { printl