**Is Your Perspective Convex or Concave?**

- Read
- Top Stories
- Write
Writer Contests Writing Prompts - Learn
Self-Paced Courses Tech Deep Dives Build Skillzz - Apply Psychology of Colors
- Auto-Generate Graphics
- Build Frontend for Ethereum dApps
- Build a Private Blockchain
- Create Generative Art with Python
- Choose the Right Kubernetes Container
- Get Featured on Product Hunt without Hunter
- Go Serverless with AWS
- Hack Smart Contracts
- Host Your Git Server on Raspberry Pi
- Implement QA Properly
- Insert Binary Tree in Rust
- Learn Anything
- Measure Technical Debt
- Protect Your Code with Gulp
- Write NFT Smart Contracts

- About
- Help
- Partner
- Shop
- Tech Co Directory

Principal component analysis (PCA) is an unsupervised technique used to preprocess and reduce the dimensionality of high-dimensional datasets while preserving the original structure and relationships inherent to the original dataset. PCA reduces the number of features that can be used to model a given use case, but also increases the computational complexity of machine learning algorithms. The results of the curse of dimensionality are said to be one of the results of a problem of analyzing data in high-dimensionality. In a real-life representation, not all users would have rated movies, so there will be a significant number of missing values.

*Learn how to train and evaluate an unsupervised machine learning model — principal component analysis in this article by Jillur Quddus, a lead technical architect, polyglot software engineer and data scientist.*

There are numerous real-world use cases, where the number of features available, which may potentially be used to train a model, is very large. A common example is economic data and using its constituents, stock price data, employment data, banking data, industrial data, and housing data together to predict the **gross domestic product** (**GDP**). Such types of data are said to have high dimensionality. Though they offer numerous features that can be used to model a given use case, high-dimensional datasets increase the computational complexity of machine learning algorithms and more importantly may also result in over fitting.

Over fitting is one of the results of the **curse of dimensionality**, which formally describes the problem of analyzing data in high-dimensional spaces (which means that the data may contain many attributes, typically hundreds or even thousands of dimensions/features) but where that analysis no longer holds true in a lower-dimensional space.

Informally, it describes the value of additional dimensions at the cost of model performance. **Principal component analysis** (**PCA**)** **is an ** unsupervised** technique used to preprocess and reduce the dimensionality of high-dimensional datasets while preserving the original structure and relationships inherent to the original dataset so that machine learning models can still learn from them and be used to make accurate predictions.

To better understand PCA, let’s study a movie recommendation use case. Our aim is to build a system that can make personalized movie recommendations to users based on historic user-community movie ratings.

The historic user-community movie ratings data that we will use for our case study has been downloaded from GroupLens, a research laboratory based at the University of Minnesota that collects movie ratings and makes them available for public download at https://grouplens.org/datasets/movielens/. For the purposes of this case study, we have transformed the individual ** movies** and

This transformed, pipe-delimited dataset can be found in the GitHub repository at https://github.com/PacktPublishing/Machine-Learning-with-Apache-Spark-Quick-Start-Guide/tree/master/Chapter05/data/movie-ratings-data and is called movie-ratings-data/user-movie-ratings.csv. You can also find the code file for this article at https://github.com/PacktPublishing/Machine-Learning-with-Apache-Spark-Quick-Start-Guide/blob/master/Chapter05/chp05-02-principal-component-analysis.ipynb.

A sample of the historic user-community movie ratings dataset that we will study looks as follows:

In this case, each movie is a different feature (or dimension) and each different user is a different instance (or observation). This sample table, therefore, represents a dataset containing 5 features. However, our actual dataset contains 3,000 different movies and therefore 3,000 features/dimensions. Furthermore, in a real-life representation, not all users would have rated all the movies, so there will be a significant number of missing values. Such a dataset, and the matrix used to represent it, is described as ** sparse**. These issues would pose a problem for machine learning algorithms, both in terms of computational complexity and the likelihood of over fitting.

To solve this problem, take a closer look at the previous sample table. It seems that users that rated Movie #1 highly (Toy Story) generally also rated Movie #2 highly (Monsters Inc.) as well. We could say, for example, that User #1 is ** representative** of all fans of computer-animated children’s films, and so we could recommend to User #2 the other movies that User #1 has historically rated highly (this type of recommendation system where we use data from other users is called

At a high level, this is what PCA does — it identifies ** typical representations**, called

Returning to our historic user-community movie ratings dataset, instead of eliminating Movie #2 entirely, we could seek to create a new feature that combines Movie #1 and Movie #2 in some manner. Extending this concept, we can create new features where each new feature is based on all the old features, and thereafter order these new features by how well they help us in predicting user movie ratings. Once ordered, we can drop the least important ones, thereby resulting in a reduction in dimensionality. So how does PCA achieve this? It does so by performing the following steps:

1. First, we standardize the original high-dimensional dataset.

2. Next, we take the standardized data and compute a covariance matrix that provides a means to measure how all our features relate to each other.

3. After computing the covariance matrix, we then find its ** eigenvectors** and corresponding

4. The eigenvectors are then sorted in descending order based on their corresponding eigenvalues, after which the top ** k **eigenvectors are selected representing the most important representations found in the data.

5. A new matrix is then constructed with these ** k** eigenvectors, thereby reducing the original

In mathematics, **variance** refers to a measure of how spread out a dataset is and is calculated by the sum of the squared distances of each data point, ** xi**, from the mean

**Covariance** refers to a measure of how strong the correlation between two or more random variables is (in our case, our independent variables) and is calculated for variables ** x** and

If the covariance is positive, this implies that the independent variables are positively correlated. If the covariance is negative, this implies that the independent variables are negatively correlated. Finally, a covariance of zero implies that there is no correlation between the independent variables. Here, we are computing the covariance between all variables.

A **covariance matrix** is a symmetric square matrix where the general element (** i**,

The covariance matrix is shown in the following table:

An identity matrix is a square matrix in which all the elements along the main diagonal are 1 and the remaining elements are 0. Identity matrices are important for when we need to find all of the eigenvectors for a matrix. For example, a 3 x 3 identity matrix looks as follows:

In linear algebra, eigenvectors are a special set of vectors whose ** direction** remains unchanged when a linear transformation is applied to it, and only changes by a

Consider a matrix, ** A**, of dimensions (

In other words,

However, in some cases, the resulting vector, ** b**, is actually a scaled version of the original vector,

We say that ** λ** is an

In order to find all the eigenvectors for a matrix, we need to solve the following equation for each eigenvalue, where ** I **is an identity matrix with the same dimensions as matrix

Once all of the eigenvectors for the covariance matrix are found, these are then sorted in descending order by their corresponding eigenvalues. Since eigenvalues represent the amount of variance in the data for that direction, the first eigenvector in the ordered list represents the principal component that captures the most variance in the original variables from the original dataset, and so on. For example, as illustrated in the figure below, if we were to plot a dataset with two dimensions or features, the first eigenvector (which will be the first principal component in order of importance) would represent the direction of most variation between the two features.

The second eigenvector (the second principal component in order of importance) would represent the direction of second-most variation between the two features:

To help choose the number of principal components, ** k**, to select from the top of the ordered list of eigenvectors, we can plot the number of principal components on the

Using this as an example, we would select around the first 300 principal components, as these describe the most variation within the data out of the 3,000 in total. Finally, we construct a new matrix by projecting the original dataset into ** k**-dimensional space represented by the eigenvectors selected, thereby reducing the dimensionality of the original dataset from 3,000 dimensions to 300 dimensions. This preprocessed and reduced dataset can then be used to train machine learning models as normal.

Let’s now return to our transformed pipe-delimited user-community movie ratings dataset, `movie-ratings-data/user-movie-ratings.csv`

, which contains ratings by 300 users covering 3,000 movies. We will develop an application in Apache Spark that seeks to reduce the dimensionality of this dataset while preserving its structure using PCA. To do this, we will go through the following steps:

1. First, let’s load the transformed, pipe-delimited user-community movie ratings dataset into a Spark dataframe using the following code. The resulting Spark dataframe will have 300 rows (representing the 300 different users) and 3,001 columns (representing the 3,000 different movies plus the user ID column):

`user_movie_ratings_df = sqlContext.read`

`.format('com.databricks.spark.csv').options(header = 'true',`

`inferschema = 'true', delimiter = '|')`

`.load('`

<Path to CSV File>`')`

`print((user_movie_ratings_df.count(),`

`len(user_movie_ratings_df.columns)))`

2. We can now generate `MLlib`

feature vectors containing 3,000 elements (representing the 3,000 features) using `MLlib`

's `VectorAssembler`

, as we have seen before. We can achieve this using the following code:

`feature_columns = user_movie_ratings_df.columns`

`feature_columns.remove('userId')`

`vector_assembler = VectorAssembler(inputCols = feature_columns,`

`outputCol = 'features')`

`user_movie_ratings_features_df = vector_assembler`

`.transform(user_movie_ratings_df)`

`.select(['userId', 'features'])`

3. Before we can reduce the dimensionality of the dataset using PCA, we first need to standardize the features that we described previously. This can be achieved using `MLlib`

's `StandardScaler`

estimator and fitting it to the Spark dataframe containing our feature vectors, as follows:

`standardizer = StandardScaler(withMean=True, withStd=True,`

`inputCol='features', outputCol='std_features')`

`standardizer_model = standardizer`

`.fit(user_movie_ratings_features_df)`

`user_movie_ratings_standardized_features_df =`

`standardizer_model.transform(user_movie_ratings_features_df)`

4. Next, we convert our scaled features into an `MLlibRowMatrix`

** **instance. A

`RowMatrix`

is a distributed matrix with no index, where each row is a vector. We achieve this by converting our scaled features data frame into an RDD and mapping each row of the RDD to the corresponding scaled feature vector. We then pass this RDD to `MLlib`

's `RowMatrix()`

(as shown in the following code), resulting in a matrix of standardized feature vectors of dimensions 300 x 3,000:`scaled_features_rows_rdd =`

`user_movie_ratings_standardized_features_df`

`.select("std_features").rdd`

`scaled_features_matrix = RowMatrix(scaled_features_rows_rdd`

`.map(lambda x: x[0].tolist()))`

5. Now that we have our standardized data in matrix form, we can easily compute the top ** k **principal components by invoking the

`computePrincipalComponents()`

method exposed by `MLlib`

's `RowMatrix`

. We can compute the top 300 principal components as follows:`number_principal_components = 300`

`principal_components = scaled_features_matrix`

`.computePrincipalComponents(number_principal_components)`

6. Now that we have identified the top 300 principal components, we can project the standardized user-community movie ratings data from 3,000 dimensions to a linear subspace of only 300 dimensions while preserving the largest variances from the original dataset. This is achieved by using matrix multiplication and multiplying the matrix containing the standardized data by the matrix containing the top 300 principal components, as follows:

`projected_matrix = scaled_features_matrix`

`.multiply(principal_components)`

`print((projected_matrix.numRows(), projected_matrix.numCols()))`

The resulting matrix now has dimensions of 300 x 300, confirming the reduction in dimensionality from the original 3,000 to only 300! We can now use this projected matrix and its PCA feature vectors as the input into subsequent machine learning models as normal.

7. Alternatively, we can use `MLlib`

's `PCA()`

estimator directly on the dataframe containing our standardized feature vectors to generate a new dataframe with a new column containing the PCA feature vectors, as follows:

`pca = PCA(k=number_principal_components, inputCol="std_features",`

`outputCol="pca_features")`

`pca_model = pca.fit(user_movie_ratings_standardized_features_df)`

`user_movie_ratings_pca_df = pca_model`

`.transform(user_movie_ratings_standardized_features_df)`

Again, this new dataframe and its PCA feature vectors can then be used to train subsequent machine learning models as normal.

8. Finally, we can extract the explained variance for each principal component from our PCA model by accessing its `explainedVariance`

attribute as follows:

`pca_model.explainedVariance`

The resulting vector (of 300 elements) shows that, in our example, the first eigenvector (and therefore the first principal component) in the ordered list of principal components explains 8.2% of the variance; the second explains 4%, and so on.

In this example, we have demonstrated how we can reduce the dimensionality of the user-community movie ratings dataset from 3,000 dimensions to only 300 dimensions while preserving its structure using PCA. The resulting reduced dataset can then be used to train machine learning models as normal, such as a hierarchical clustering model for collaborative filtering.

*If you found this article interesting, you can explore **Machine Learning with Apache Spark Quick Start Guide** to combine advanced analytics including machine learning, deep learning neural networks and natural language processing with modern scalable technologies including apache spark to derive actionable insights from big data in real-time. **Machine Learning with Apache Spark Quick Start Guide** can help you become familiar with advanced techniques for processing a large volume of data by applying machine learning algorithms.*