VectorIndexer pyspark

from pyspark.ml import Pipeline
from pyspark.ml.regression import LinearRegression
from pyspark.ml.feature import VectorIndexer
from pyspark.ml.evaluation import RegressionEvaluator

# Automatically identify categorical features, and index them.
# We specify maxCategories so features with > 4 distinct values are treated as continuous.

featureIndexer = VectorIndexer(inputCol="features", \
                               outputCol="indexedFeatures",\
                               maxCategories=4).fit(transformed)

data = featureIndexer.transform(transformed)

Source: runawayhorse001.github.io

Similar codes

0 vote290 views1 answer
How to capitalize words in python
Python
0 vote313 views1 answer
Print items of list using list comprehension in python
Python
81 votes307 views6 answers
How to clear console in python
Python
0 vote312 views1 answer
Pickled list
Python
6 votes365 views2 answers
Flask get ip address of request
Python Flask
13 votes274 views2 answers
Try catch if else python
Python
0 vote331 views1 answer
Python path from string
Python
1 vote281 views1 answer
How to make a hidden file in python
Python
0 vote324 views1 answer
Scipy.cluster.hierarchy
Python
1 vote337 views1 answer
How to send json in django response
Python