我有一个来自 cassandrasql 的数据框,我有一个列,它是数据框中的地图,例如
scala> df.printSchema
root
|-- client: map (nullable = true)
| |-- key: string
| |-- value: string (valueContainsNull = true)
我需要从 df 中选择一些列以及从地图中选择特定键作为 df 中的列,而不是完整的地图
假设我有一个 key1 -> value1 key2 -> value2 ...的映射。
我只需要从数据框中的地图中选择 key1 作为新数据框中的一列。我怎样才能做到这一点
另外我正在使用 cassandrasqlcontext.sql 来获取数据框。