make_timestamp_ltz

Vytvořte aktuální časové razítko s místním časovým pásmem z polí roky, měsíce, dny, hodiny, miny, sekundy a časové pásmo. Pokud je konfigurace spark.sql.ansi.enabled false, vrátí funkce hodnotu NULL pro neplatné vstupy. Jinak se místo toho vyvolá chyba.

Syntaxe

from pyspark.sql import functions as dbf

dbf.make_timestamp_ltz(years=<years>, months=<months>, days=<days>, hours=<hours>, mins=<mins>, secs=<secs>, timezone=<timezone>)

Parametry

Parameter	Typ	Description
years	pyspark.sql.Column nebo str	Rok, který má představovat, od 1 do 9999
months	pyspark.sql.Column nebo str	Měsíc v roce, který má představovat od 1 (leden) do 12 (prosinec)
days	pyspark.sql.Column nebo str	Den v měsíci představující od 1 do 31
hours	pyspark.sql.Column nebo str	Hodina dne, která má být reprezentovaná od 0 do 23
mins	pyspark.sql.Column nebo str	Minuta hodina, která má představovat od 0 do 59
secs	pyspark.sql.Column nebo str	Druhá minuta a její mikro-zlomek, které představují, od 0 do 60. Hodnota může být celé číslo jako 13 nebo zlomek jako 13,123. Pokud se argument sekund rovná 60, pole sekund se nastaví na 0 a 1 minutu se přidá do konečného časového razítka.
timezone	pyspark.sql.Column nebo str, optional	Identifikátor časového pásma. Například CET, UTC a atd.

Návraty

pyspark.sql.Column: Nový sloupec, který obsahuje aktuální časové razítko.

Examples

spark.conf.set("spark.sql.session.timeZone", "America/Los_Angeles")

from pyspark.sql import functions as dbf
df = spark.createDataFrame([[2014, 12, 28, 6, 30, 45.887, 'CET']],
['year', 'month', 'day', 'hour', 'min', 'sec', 'tz'])
df.select(
dbf.make_timestamp_ltz(df.year, df.month, 'day', df.hour, df.min, df.sec, 'tz')
).show(truncate=False)
df = spark.createDataFrame([[2014, 12, 28, 6, 30, 45.887, 'CET']],
['year', 'month', 'day', 'hour', 'min', 'sec', 'tz'])
df.select(
dbf.make_timestamp_ltz(df.year, df.month, 'day', df.hour, df.min, df.sec)
).show(truncate=False)
spark.conf.unset("spark.sql.session.timeZone")