2016-07-14 106 views
10

語境:我有一個DataFrame 2列:字和載體。其中「矢量」的列類型爲VectorUDT如何矢量拆分成多列 - 使用PySpark

一個例子:

word | vector 

assert | [435,323,324,212...] 

,我想這一點:

word | v1 | v2 | v3 | v4 | v5 | v6 ...... 

assert | 435 | 5435| 698| 356|.... 

問:

我怎麼能在幾列與向量拆分列每個維度使用pyspark?

在此先感謝

回答

16

一種可能的方法是轉換和從RDD:

from pyspark.ml.linalg import Vectors 

df = sc.parallelize([ 
    ("assert", Vectors.dense([1, 2, 3])), 
    ("require", Vectors.sparse(3, {1: 2})) 
]).toDF(["word", "vector"]) 

def extract(row): 
    return (row.word,) + tuple(row.vector.toArray().tolist()) 

df.rdd.map(extract).toDF(["word"]) # Vector values will be named _2, _3, ... 

## +-------+---+---+---+ 
## | word| _2| _3| _4| 
## +-------+---+---+---+ 
## | assert|1.0|2.0|3.0| 
## |require|0.0|2.0|0.0| 
## +-------+---+---+---+ 

另一種解決方案是創建一個UDF:

from pyspark.sql.functions import udf, col 
from pyspark.sql.types import ArrayType, DoubleType 

def to_array(col): 
    def to_array_(v): 
     return v.toArray().tolist() 
    return udf(to_array_, ArrayType(DoubleType()))(col) 

(df 
    .withColumn("xs", to_array(col("vector"))) 
    .select(["word"] + [col("xs")[i] for i in range(3)])) 

## +-------+-----+-----+-----+ 
## | word|xs[0]|xs[1]|xs[2]| 
## +-------+-----+-----+-----+ 
## | assert| 1.0| 2.0| 3.0| 
## |require| 0.0| 2.0| 0.0| 
## +-------+-----+-----+-----+ 
+0

在性能方面,它是使用'.map/.toDF'函數更聰明得多,因爲它們幾乎總是比UDF實現更快。 [除非你使用spark 2.2的矢量化udf定義] – tmarthal