Skip to content

Instantly share code, notes, and snippets.

@sujee

sujee/spark-one-hot.py

Last active February 1, 2021 19:16
Show Gist options
  • Save sujee/1c213dfe448f6f09ca29ec8f469c0271 to your computer and use it in GitHub Desktop.
Save sujee/1c213dfe448f6f09ca29ec8f469c0271 to your computer and use it in GitHub Desktop.
Download ZIP
Spark one hot encoding sample
Raw
spark-one-hot.py
## Step 3 : encode the indexes into a vector
from pyspark.ml.feature import OneHotEncoder
encoder = OneHotEncoder(inputCols=["statusIndex"], outputCols=["statusVector"], dropLast=False)
encoded = encoder.fit(indexed).transform(indexed)
encoded.show()
# View dense vectors in pandas
encoded_pd = encoded.toPandas()
print(encoded_pd)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment