inclinação_reg

Função agregada: retorna a inclinação da linha de regressão linear para pares não nulos em um grupo, onde y é a variável dependente e x é a variável independente.

Sintaxe

Python

from pyspark.sql import functions as sf

sf.regr_slope(y, x)

Parâmetros

Parâmetro	Tipo	Descrição
y	pyspark.sql.Column ou str	A variável dependente.
x	pyspark.sql.Column ou str	A variável independente.

Devoluções

pyspark.sql.Column: a inclinação da reta de regressão linear para pares não nulos em um grupo.

Exemplos

Exemplo 1 : Todos os pares são não nulos.

Python

from pyspark.sql import functions as sf
df = spark.sql("SELECT * FROM VALUES (1, 1), (2, 2), (3, 3), (4, 4) AS tab(y, x)")
df.select(sf.regr_slope("y", "x")).show()

Output

+----------------+
|regr_slope(y, x)|
+----------------+
|             1.0|
+----------------+

Exemplo 2 : Todos os valores de x dos pares são nulos.

Python

from pyspark.sql import functions as sf
df = spark.sql("SELECT * FROM VALUES (1, null) AS tab(y, x)")
df.select(sf.regr_slope("y", "x")).show()

Output

+----------------+
|regr_slope(y, x)|
+----------------+
|            NULL|
+----------------+

Exemplo 3 : Os valores y de todos os pares são nulos.

Python

from pyspark.sql import functions as sf
df = spark.sql("SELECT * FROM VALUES (null, 1) AS tab(y, x)")
df.select(sf.regr_slope("y", "x")).show()

Output

+----------------+
|regr_slope(y, x)|
+----------------+
|            NULL|
+----------------+