私は 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 クエリのみを使用できます。