make_dt_interval

Buat durasi DayTimeIntervalType dari hari, jam, menit, dan detik.

Untuk fungsi Databricks SQL yang sesuai, lihat make_dt_interval fungsi.

Syntax

from pyspark.databricks.sql import functions as dbf

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

Parameter-parameternya

Pengaturan	Tipe	Description
days	pyspark.sql.Column atau str, optional	Jumlah hari, positif atau negatif.
hours	pyspark.sql.Column atau str, optional	Jumlah jam, positif atau negatif.
mins	pyspark.sql.Column atau str, optional	Jumlah menit, positif atau negatif.
secs	pyspark.sql.Column atau str, optional	Jumlah detik dengan bagian pecahan dalam presisi mikrodetik.

Pengembalian Barang

pyspark.sql.Column: Kolom baru yang berisi durasi DayTimeIntervalType.

Examples

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)