3

cassandrasql のデータフレームがあり、次のようなデータフレームのマップである列があります

scala> df.printSchema
root
 |-- client: map (nullable = true)
 |    |-- key: string
 |    |-- value: string (valueContainsNull = true)

完全なマップではなく、dfの列としてマップから特定のキーを選択するだけでなく、dfからいくつかの列を選択する必要があります

key1 -> value1 key2 -> value2 のマップがあるとしましょう ....

新しいデータフレームの列になるには、データフレームのマップから key1 のみを選択する必要があります。どうやってやるの

また、cassandrasqlcontext.sql を使用してデータフレームを取得しています。

4

3 に答える 3

2

SparkSQL の使用 (データフレームを「df」として登録したと仮定)

context.registerDataFrameAsTable(df,"df")
val newDf =context.sql("select client.key,client.value from df where client.key='some value'")
于 2015-07-16T06:00:56.853 に答える