2

私は Spark と Spark SQL を試しており、次のように (結合を使用して) 選択からの出力として取得する文字列フィールドの先頭に値を連結する必要があります。

val result = sim.as('s)   
    .join(
        event.as('e),
        Inner,
        Option("s.codeA".attr === "e.codeA".attr))   
    .select("1"+"s.codeA".attr, "e.name".attr)  

私のテーブルに含まれているとしましょう:

シム:

codeA,codeB
0001,abcd
0002,efgh

イベント:

codeA,name
0001,freddie
0002,mercury

そして、私は出力として欲しい:

10001,freddie
10002,mercury

SQL または HiveQL でconcat関数を使用できることはわかっていますが、Spark SQL はこの機能をサポートしていないようです誰かが私の問題の回避策を提案できますか?

ありがとうございました。

:言語統合クエリを使用していますが、最終的な解決策の場合には、「標準の」Spark SQL クエリのみを使用できます。

4

2 に答える 2