expr(expr)
Описание
Функция expr() вычисляет SQL-выражение.
Параметры
expr: String - SQL-выражение
Возвращаемое значение
Тип данных результата выражения
Пример использования
from pyspark.sql.functions import expr
from pyspark.sql import SparkSession
# Создаем SparkSession
spark = SparkSession.builder.appName("expr_example").getOrCreate()
# Создаем DataFrame с данными
data = [(1, 2), (3, 4), (5, 6)]
df = spark.createDataFrame(data, ["a", "b"])
# Вычисляем выражение
result = df.select(
expr("a + b").alias("sum"),
expr("a * b").alias("product")
).show()
# Результат:
# +---+-------+
# |sum|product|
# +---+-------+
# |3 |2 |
# |7 |12 |
# |11 |30 |
# +---+-------+