Corr

Sütun1 ve sütun2 için Pearson Korelasyon Katsayısı'na ait yeni bir sütunu döndürür.

Sözdizimi

from pyspark.sql import functions as sf

sf.corr(col1, col2)

Parametreler

Parametre	Türü	Description
col1	pyspark.sql.Column veya sütun adı	Bağıntıyı hesaplayan ilk sütun.
col2	pyspark.sql.Column veya sütun adı	bağıntıyı hesaplamak için ikinci sütun.

İade

pyspark.sql.Column: Bu iki sütun değerinin Pearson Bağıntı Katsayısı.

Örnekler

from pyspark.sql import functions as sf
a = range(20)
b = [2 * x for x in range(20)]
df = spark.createDataFrame(zip(a, b), ["a", "b"])
df.agg(sf.corr("a", df.b)).show()

+----------+
|corr(a, b)|
+----------+
|       1.0|
+----------+