window_time

Olay zamanını bir pencere sütunundan hesaplar. Sütun penceresi değerleri, pencere toplama işleçleri tarafından oluşturulur ve başlangıcın dahil olduğu ve sonun özel olduğu türdedir STRUCT<start: TIMESTAMP, end: TIMESTAMP> . Pencere toplama işleçleri tarafından üretilen kayıtların olay süresi ve window_time(window) olarak window.end - lit(1).alias("microsecond") hesaplanabilir (mikrosaniye, desteklenen en düşük olay süresi duyarlığıdır). Pencere sütunu, bir pencere toplama işleci tarafından üretilen bir sütun olmalıdır.

İlgili Databricks SQL fonksiyonu için bakınız window_time fonksiyonu.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.window_time(windowColumn=<windowColumn>)

Parametreler

Parametre	Türü	Description
windowColumn	pyspark.sql.Column veya str	Bir pencerenin pencere sütunu kayıtları toplar.

İade

pyspark.sql.Column: hesaplanan sonuçlar için sütun.

Örnekler

import datetime
from pyspark.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'))