user-defined-functions

4熱

2答えて

が私のデータが設定されて使用されます。 FullName <- c("Jimmy John Cephus", "Frank Chester", "Hank Chester", "Brody Buck Clyde", "Merle Rufus Roscoe Jed Quaid") df <- data.frame(FullName) 目標：「」、任意のスペースのフルネームに見て、と姓を抽出しま

0熱

1答えて

ハイブUDF、Javaプリミティブ、ヌル

E. CaprioloらのProgramming Hiveの168ページに、「... Javaプリミティブはオブジェクトではなく、nullにはなりません」と記載されています。だから、簡単なハイブUDF用： public class ConvertToCelcius extends UDF { public double evaluate(double value) { ret

0熱

2答えて

スパークは、私は、スパークプロジェクトをやっているとニーズが最善の方法で、以下の問題を解決する方法について助言小さなファイル

から見上げます。形式は次のとおりです（name：String、value：Int）。下記の内容例： Davi,130 Joel,20 Emma,500 私はこのようなレコードの4行で別の小さなファイル、（クラス名：文字列、のminValue：INT、maxValueの：INT）持っている今、私はクラスを検索してファイルを作成が必要名前最小値と最大値、以下上記のレコードの出力間の値に基づい

0熱

2答えて

PySparkでブロードキャストオブジェクトを使用してUDFを呼び出すときのエラー

PySparkでブロードキャストオブジェクトを使用するUDFを呼び出そうとしています。ここでは、状況やエラーを再現し、最小限の例です。このスニペットが生成する import pyspark.sql.functions as sf from pyspark.sql.types import LongType class SquareClass: def compute(self,

0熱

1答えて

DB2400外部ユーザー定義表関数を作成しますか？

私はDB2400でUDTFを作成しようとしています私は呼び出したいILE CLプログラムを持っています。プログラムが作成され、私が望むように実行されます。私は select * from table(smlfqa.xajjuc_le('xxxxx')) a 私は select * from table(smlfqa.xajjuc_le('xxxxx')) a [SQL0204] XAJ

1熱

1答えて

ユーザー定義関数をデバッグする方法

以下のユーザー定義関数は重複を引き起こし、ビルドに失敗します。関数の各部分をテストするための最良の方法は何ですか？問題の原因を特定できますか？そして援助は大きな利益になるでしょう。ユーザー定義関数に挿入する前にコードを選択して最初に実行すると仮定したので、関数をデバッグする必要はありませんでした。 USE [HealthBI] GO /****** Object: UserDefinedF

0熱

1答えて

メインクラスにpyspark UDFをインポートする方法

私は2つのファイルを持っています。 functions.pyには機能があり、その機能からpyspark udfが作成されます。 main.py udfをインポートしようとしました。ただし、main.pyはfunctions.pyの機能にアクセスするのに問題があるようです。 functions.py： from pyspark.sql.functions import udf from pyspa

0熱

2答えて

遅いUDFへのSQLの代替

UDTの2つのパラメーターを使用する照会には0.3秒かかりますが、インライン表の値を持つ関数にカプセル化されている場合は3.5+秒かかります。私は（Why is a UDF so much slower than a subquery?）を読んだことがありますが、修正/書き換えには苦労しています。以下@ JasonALongのフィードバックパー、0.3秒で完了SELECT文の実行計画：htt

3熱

1答えて

Scalaで関数の定義を出力することは可能ですか

Scalaで関数の定義を出力できるかどうかは疑問でした。 Scalaでは関数がオブジェクトとして扱われます。例えば：スカラ>ヴァルsplitFunction =（値：文字列）=> {value.split（」「）}上 splitFunction: String => Array[String] = <function1> 、スカラインタラクティブシェルはsplitFunction入力パラメ

0熱

1答えて

SparkSQL UDFは、列名がUDF（ "元の列名"）の形式のデータフレームを返すのはなぜですか？

したがって、次のコードを実行した後に取得するデータフレームは、正確に私が望む方法です。元のデータフレームと同じデータフレームですが、純粋な数値データを持つすべてのセルには、すべての角かっことスラッシュが削除されています（角かっこは正面のマイナス記号に置き換えられています）。 stringModifierIteratorはデータフレームを取り込んでList [Column]を返します。 List [