window_time

Menghitung waktu peristiwa dari kolom jendela. Nilai jendela kolom dihasilkan oleh operator agregasi jendela dan berjenis STRUCT<start: TIMESTAMP, end: TIMESTAMP> di mana mulai bersifat inklusif dan berakhir bersifat eksklusif. Waktu peristiwa rekaman yang dihasilkan oleh operator agregasi jendela dapat dihitung sebagai window_time(window) dan ( window.end - lit(1).alias("microsecond") karena mikrodetik adalah presisi waktu peristiwa yang didukung minimal). Kolom jendela harus satu yang dihasilkan oleh operator agregasi jendela.

Untuk fungsi Databricks SQL yang sesuai, lihat window_time fungsi.

Syntax

from pyspark.databricks.sql import functions as dbf

dbf.window_time(windowColumn=<windowColumn>)

Parameter-parameternya

Pengaturan	Tipe	Description
windowColumn	pyspark.sql.Column atau str	Kolom jendela rekaman agregat jendela.

Pengembalian Barang

pyspark.sql.Column: kolom untuk hasil komputasi.

Examples

import datetime
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(datetime.datetime(2016, 3, 11, 9, 0, 7), 1)], ['dt', 'v'])

df2 = df.groupBy(dbf.window('dt', '5 seconds')).agg(dbf.sum('v'))