udf

0熱

1答えて

Spark 2.1.1：ストラクチャードストリーミングクエリに変数をバインドする方法

変数を使用して、2つの変数値の範囲内のエントリを選択したいとします。私のSQLクエリはString sql = "Select count(*) FROM Records WHERE event_time <= UPPERTIME('1') AND event_time >= LOWERTIME('1')";です。このクエリUPPERTIME('1')とLOWERTIME('1')でUDFとそこ定

0熱

1答えて

スカラーのhive udfでnullを返すには？

私はスカラ座 class MyUDF extends UDF { def func(a: Double): Double { if (cond){ how to return null in this case? } else {some double} } } にハイブUDFに取り組んでいます私はnull.asInstanceOf[Double]

0熱

3答えて

方法：マップなしでaerospike udfフィルターを作成するか、マップに完全なレコードを返します

Aerospikeにフィルタとマップを含むudfストリームがあります。私が見たすべての例によると、私はレコードからフィールドを選び、フィルタリングされ選択されたフィールドを持つ新しいマップを返すことができます。しかし、私はそれをしたくありません。私はどのようなストリームでも、どんなコラム/ビンでも、フィルタを適用してフルレコードを返すことを望みます。 1つのアプローチは、stream：fiter

0熱

1答えて

DataFrameを使用してテーブルの各列をスカラーで比較するにはどうすればいいですか？

私が以前に尋ねた質問は次のとおりです。 Last question 表1 - IDペアテーブル表2 - 属性テーブル表3 たとえば、id1とid2の色とサイズが異なるため、id1とid2の行（表3の2行目）には「id1 id2 0 0」があります。 id1とid3は同じ色でサイズが異なるため、id1とid3の行（表3の3行目）は "id1 id3 1 0"です。同じ属性---私は表2でどのよ

1熱

1答えて

Excel2011：VlookupとCombine

私は70000+のラインで欲しいことをするためにいくつかの機能を組み合わせるのにいくつかの困難を抱えています。任意のヒントやポインタやアドバイスを大いに感謝します。私は2列（約70000行分）持っています。列1にはクライアントの口座番号があります（重複があります）。列2の横には抽出したいデータがあります。私はまた、口座番号のリストですが、重複を取り除かれた3番目の列（3列目）を持っています。私は

2熱

1答えて

ユーザーが予想以上の引数を入力したときにMboxを表示するには、VBAのUDFを強制しますか？

ユーザーがCOUNTBLANK機能のためにあまりにも多くの引数を入力すると、関数はこのエラーメッセージが表示され、編集モードに戻ります：あなたはこの機能のためにあまりにも多くの引数を入力しました。どのようにUDFを作成するのですか？例えば：デフォルトでは Function COUNT2 (c As Range) COUNT2 = c.Count End Function この

1熱

1答えて

カサンドラ集計関数 "first_row"

私は知っている、そのカサンドラはGROUP BYを許可し、そのデータにUDFを実行することができます。各集約セットの最初の行を取得する既定の関数はありますか？（How）データの処理を停止し、すぐに私のUDFの結果を返すことができますか（E.G. 1または数行処理後）？今は回避策として... COUNT(1) ...を使用しています。

0熱

1答えて

シリアル化可能でないオブジェクトを含むSparkSQL UDFを作成する

sqlContextのHiveテーブルで使用したいUDFを作成しようとしています。シリアライズ可能でない他のライブラリのオブジェクトを含めることは、いかなる方法で可能ですか？ここでは動作しないものの最小限の例です： def myUDF(s: String) = { import sun.misc.BASE64Encoder val coder= new BASE64Encoder val e

5熱

1答えて

Spark SQL withColumnを入れ子にしました

私は、複数の列があり、それらのうちのいくつかが構造体であるDataFrameを持っています。私はbazの機能をbazを置き換えるために、列bazにUserDefinedFunctionを適用したいが、私はそれを行う方法を見つけ出すことはできません。この root |-- foo: struct (nullable = true) | |-- bar: string (nullable = tr

0熱

1答えて

なぜSQLサーバーが正しい値の代わりにテーブルに0の値を挿入するのですか？

誰かが私がアイデアから完全に脱出してくれることを願っています。私は現在、プレミアリーグの試合結果に関する分析を行っており、その一環として、マルチステートメントテーブルUDFを作成しました。この関数はHomeTeam、AwayTeamとMatchDateパラメータを受け入れ、その後、前に指定されたアップマッチの日に、勝っ描かれたり、家庭でアウェイチームの間で歴史的に失われた各試合の結果のカウント