user-defined-functions

-5熱度

1回答

我是編程/編程方面的新手，我從Python的基礎入手。我已經使用了一些不同的資源（Codecademy，自動化乏味的東西，以及最近的使用Python如何像計算機科學家一樣思考）。到目前爲止，我的教育一直很好，雖然開始有點慢（不習慣用電腦術語思考！）。但是我遇到了一個我無法在IDE中複製的課程。請參閱下面的代碼： def printTwice(bruce): print('bruce')

3熱度

1回答

在UDF中獲得值WrappedArray <WrappedArray <Double>> Java

我的Dataset<Row>中有一列包含WrappedArray<WrappedArray<Double>>。我將這一列傳遞給UDF以提取其中一個值。我該如何去訪問這個嵌套結構中的Doubles？我想要做這樣的事情： sparkSession.udf().register(ADD_START_TOTAL, (UDF1<WrappedArray<WrappedArray<Double>>, Do

1熱度

1回答

SQL Sever 2016更改表值函數 - 更改安全策略

我有一個表值函數正在被安全策略引用。我想ALTER的功能，但我不能： Msg 3729, Level 16, State 3, Procedure accessPredicate, Line 1 Cannot ALTER 'rls.accessPredicate' because it is being referenced by object 'EventSecurityPolicy' 嗯，但

1熱度

2回答

如何創建一個Pyspark UDF用於將新列添加到數據框中

我有5列要添加到數據框中。（A - E）這些列的值存儲在（a - e）變量中。而不是使用 df.withColumn("A", a).withColumn("B", b).withColumn..... etc 的，我們能做到這一點有一個UDF？目前我點名功能： def add_col(df_name,newCol,value): df = df_name df

-6熱度

2回答

需要幫助調用一個輸入作爲參數

def leap_year(year): year = input() if year % 4 == 0 and year % 100 != 0 or year % 400 == 0: return True else: return False 如何調用此函數？

0熱度

1回答

斯卡拉錯誤我有我下面的Scala代碼故障功能

內部處理： class ClassMyHelper { protected var logger: Logger = LogManager.getLogger(classOf[AvroHelper]) def somefunc(schema: Schema, datum: GenericRecord): Array[Byte] = { <code> va

2熱度

2回答

將案例類傳遞給Spark UDF

我有一個scala-2.11函數，它根據提供的類類型從Map創建一個case類。 def createCaseClass[T: TypeTag, A](someMap: Map[String, A]): T = { val rMirror = runtimeMirror(getClass.getClassLoader) val myClass = typeOf[T].type

0熱度

1回答

在Spark數據集中使用custome UDF withColumn <Row>; java.lang.String不能轉換爲org.apache.spark.sql.Row

我有一個包含許多字段的JSON文件。我在java中使用spark的Dataset讀取文件。星火版本2.2.0 JAVA JDK 1.8.0_121 下面是代碼。 SparkSession spark = SparkSession .builder() .appName("Java Spark SQL basic example") .config(

1熱度

1回答

VBA用戶定義函數＃VALUE錯誤

我有四個片材：投資 sample row-1: ABC, INV_ID1 sample row-2: ABC, INV_ID2 sample row-3: XYZ, INV_ID3 sample row-4: XYZ, INV_ID4 RETURNS-ABC sample row: date1, status_INV_ID_1, returns_INV_ID_1,

0熱度

1回答

使用UDF火花

輸入轉換字符串的嵌套數組類型迄今爲止的嵌套數組類型： f1 : [["2017-08-08","2017/08/08"],["2017-08-08","2017/08/08"]] 架構F1：ArrayType(ArrayType(StringType)) 我想日期值從字符串中使用的火花UDF轉換爲日期格式。這裏輸入可能有Array[Any]。我已經寫了udf，它適用於像["2017-08-0