Поделиться через


Elt

Возвращает входные nданные -th, например, возвращает input2 значение n 2. Функция возвращает значение NULL, если индекс превышает длину массива и spark.sql.ansi.enabled имеет значение false. Если spark.sql.ansi.enabled задано значение true, он создает массив ArrayIndexOutOfBoundsException для недопустимых индексов.

Для соответствующей функции Databricks SQL смотрите функцию elt.

Синтаксис

from pyspark.databricks.sql import functions as dbf

dbf.elt(*inputs=<*inputs>)

Параметры

Параметр Тип Description
inputs pyspark.sql.Column или str Входные столбцы или строки.

Примеры

df = spark.createDataFrame([(1, "scala", "java")], ['a', 'b', 'c'])
df.select(elt(df.a, df.b, df.c).alias('r')).collect()
[Row(r='scala')]