メインコンテンツまでスキップ

dt間隔を作る

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

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

構文

Python
from pyspark.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

小数部がマイクロ秒精度の秒数。

パラメーター

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.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)
このページの見出し