make_dt_interval

Создайте длительность для DayTimeIntervalType из дней, часов, минут и секунд.

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

Синтаксис

from pyspark.databricks.sql import functions as dbf

dbf.make_dt_interval(days=<days>, hours=<hours>, mins=<mins>, secs=<secs>)

Параметры

Параметр	Тип	Description
days	pyspark.sql.Column или str, optional	Количество дней, положительное или отрицательное.
hours	pyspark.sql.Column или str, optional	Количество часов, положительное или отрицательное.
mins	pyspark.sql.Column или str, optional	Количество минут, положительное или отрицательное.
secs	pyspark.sql.Column или str, optional	Количество секунд с дробной частью в микросекундах точности.

Возвраты

pyspark.sql.Column: новый столбец, содержащий длительность DayTimeIntervalType.

Примеры

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([[1, 12, 30, 01.001001]], ['day', 'hour', 'min', 'sec'])
df.select('*', dbf.make_dt_interval(df.day, df.hour, df.min, df.sec)).show(truncate=False)
df = spark.createDataFrame([[1, 12, 30, 01.001001]], ['day', 'hour', 'min', 'sec'])
df.select('*', dbf.make_dt_interval(df.day, 'hour', df.min)).show(truncate=False)
df = spark.createDataFrame([[1, 12, 30, 01.001001]], ['day', 'hour', 'min', 'sec'])
df.select('*', dbf.make_dt_interval(df.day, df.hour)).show(truncate=False)
df = spark.createDataFrame([[1, 12, 30, 01.001001]], ['day', 'hour', 'min', 'sec'])
df.select('*', dbf.make_dt_interval('day')).show(truncate=False)
spark.range(1).select(dbf.make_dt_interval()).show(truncate=False)