mevcut_zaman

Sorgu değerlendirmesinin başlangıcındaki geçerli saati TimeType sütunu olarak döndürür. Aynı sorgu içindeki current_time tüm çağrıları aynı değeri döndürür.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.current_time(precision=<precision>)

Parametreler

Parametre	Türü	Description
precision	intopsiyonel	[0..6] aralığındaki sayı, saniyelerin kaç kesirli basamağı eklendiğini gösterir. Atlanırsa, varsayılan değer 6'dır.

İade

pyspark.sql.Column: Geçerli saat.

Örnekler

Örnek 1: Varsayılan duyarlıklı geçerli saat

from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time().alias("time")).show()

+---------------+
|           time|
+---------------+
|16:57:04.304361|
+---------------+

Örnek 2: Belirtilen duyarlık ile geçerli saat

from pyspark.sql import functions as dbf
spark.range(1).select(dbf.current_time(3).alias("time")).show()

+------------+
|        time|
+------------+
|16:57:04.304|
+------------+