dt間隔を作る

DayTimeIntervalType の期間を日、時間、分、秒から作成します。

対応する Databricks SQL 関数については、 make_dt_interval関数を参照してください。

構文

Python

from pyspark.databricks.sql import functions as dbf

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

パラメーター

パラメーター	Type	説明
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 期間を含む新しい列。

例

Python

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)