我想使用开始和长度定义为Column
(s)的Spark slice函数。
def slice(x: Column, start: Int, length: Int): Column
x
看起来像这样:
`|-- x: array (nullable = true)
| |-- element: struct (containsNull = true)
| | |-- a: double (nullable = true)
| | |-- b : double (nullable = true)
| | |-- c: double (nullable = true)
| | |-- d: string (nullable = true)
| | |-- e: double (nullable = true)
| | |-- f: double (nullable = true)
| | |-- g: long (nullable = true)
| | |-- h: double (nullable = true)
| | |-- i: double (nullable = true)
...
`
有关于如何实现这一点的想法吗?
谢谢!
https://stackoverflow.com/questions/54027488
复制相似问题