udf

0熱

2答えて

状況：私はエアロで複雑なビンを持っているように： OBJECT_ID、ステータス、CREATE_TIME、end_at_time、status_client、assigned_to_id、created_by_id、is_s_provider、is_s_client、start_at_time、_id、END_TIME そして、私はいずれかのビンフィールドで集約を行う必要があります。以下のように

1熱

2答えて

SQL Server UDFは、値nullの変数が渡されるときと定数nullが渡されたときとで動作が異なる場合があります

これは、フィルタパラメータを必要とするかどうかにかかわらず、高価な作業を伴うストアドプロシージャを作成しています。フィルタリング自体が非常に高価であり、フィルタリングされるテーブルが大きくなります。私は、内部フィルタリング関数を変更しようとしました。そのため、無効なパラメータで呼び出された場合はエラーをスローします。しかし、私がNULLで外側のテスト関数を呼び出すと、内部関数を呼び出しずにエラー

0熱

1答えて

はハイブカスタムUDFドキュメントを説明します

ハイブで使用できるJavaでカスタムUDFを作成しました。このUDFにドキュメントを追加する方法と場所を教えてください。このドキュメントを表示するには、DESCRIBE FUNCTION <CUSTOM UDF>にハイブをつけてください。

0熱

2答えて

Spark SQL - 2つの日付と時刻の差を計算するためのUDF

2つの日付と時刻の差を計算するためのSpark SQL UDFはありますか？

0熱

4答えて

日付範囲のUDFまたは標準IF関数？

私は列の数値から範囲を作成し、範囲を作成しようとしています。例えば、 column F: 1899 1912 1915 1918 1929 1934 1935 1936 ... ので、すぐに1934年、1935年、1936年などのシーケンスが開始されると、それは1934年をキャプチャなり、その差はこの例の結果は次のようになりません。1. になるまで反復処理： 1934 - 1

5熱

1答えて

spark UDFを使用して複合型を返す方法

こんにちは、ありがとうございます。私のプログラムはjavaで書かれており、私はscalaに移動できません。私は現在、次の行を使用してJSONファイルから抽出されたスパークDATAFRAMEで働いています： DataFrame dff = sqlContext.read().json("filePath.son"); SQLContextとSparkContextが正しくinitialziedさ

2熱

2答えて

選択時に大きなクエリUDFを使用する

私はuuidとユーザのためのいくつかの他の値を含むテーブルを持っています。また、私はMD5とCRC32値に基づいて、与えられたUUIDによってUSER_GROUP計算BQに次のUDFの機能を持っている： function GetGroup(uuid) {... } function getUserGroup(r, emit) { emit ({group: GetGroup(String

0熱

1答えて

ハイブパッケージをインポートする際にエラーが発生しました

ハイブのudfを初めて使用しました。私は "apache-hive-2.1.0-bin"をダウンロードし、私のプロジェクトのビルドパスをapache-hive-2.1.0-bin\lib（すべてのjarファイル）に設定しました。 import org.apache.hadoop.hive.ql.exec.UDF; import org.apache.hadoop.io.Text; // <= I

0熱

3答えて

ハイブ配列比較関数/ udfのものはありますか

ハイブに配列比較関数/ udfがあるかどうかはarray=arrayですか？例えば：あなたはそれを含む配列を返す array_diff($array1,$array2); によって2つの配列の値を比較することができCとDが配列