fay*_*rmd 8 python apache-spark pyspark apache-spark-mllib
我的python版本是3.6.3,spark版本是2.2.1。这是我的代码:
from pyspark.ml.linalg import Vectors
from pyspark.ml.feature import VectorAssembler
from pyspark import SparkContext, SparkConf
from pyspark.sql import SparkSession
sc = SparkContext()
spark = SparkSession.builder.appName("Data Preprocessor") \
.config("spark.some.config.option", "1") \
.getOrCreate()
dataset = spark.createDataFrame([(0, 59.0, 0.0, Vectors.dense([2.0, 0.0,
0.0, 0.0, 0.0, 0.0, 0.0, 9.0, 9.0, 9.0]), 1.0)],
["id", "hour", "mobile", "userFeatures", "clicked"])
assembler = VectorAssembler(inputCols=["hour", "mobile", "userFeatures"],
outputCol="features")
output = assembler.transform(dataset)
output.select("features").show(truncate=False)
Run Code Online (Sandbox Code Playgroud)
我没有得到单个向量,而是得到以下输出:
(12,[0,2,9,10,11],[59.0,2.0,9.0,9.0,9.0])
ash*_*ids 11
vectorAssembler 返回的向量是 sparseVector 形式。12 是特征的数量。([0,2,9,10,11]) 是非零值的索引。[59.0,2.0,9.0,9.0,9.0] 是非零值。
归档时间: |
|
查看次数: |
1867 次 |
最近记录: |