How to calculate correlation matrix (with all columns at once) in pyspark dataframe?

[washim · Accepted solution]

got it use -

features = dataset.map(lambda row: row[0:])

from pyspark.mllib.stat import Statistics

corr_mat=Statistics.corr(features, method="pearson")