curdate()

Описание

Функция curdate() возвращает текущую дату в формате DateType.

Параметры

Функция не принимает параметров.

Возвращаемое значение

Date - текущая дата

Пример использования

from pyspark.sql import SparkSession
from pyspark.sql.functions import curdate

# Создаем SparkSession
spark = SparkSession.builder.appName("curdate_example").getOrCreate()

# Создаем DataFrame
data = [
    (1,),
    (2,),
    (3,)
]
df = spark.createDataFrame(data, ["id"])

# Добавляем текущую дату
result = df.select(
    "id",
    curdate().alias("current_date")
).show()

# Результат:
# +---+------------+
# | id|current_date|
# +---+------------+
# |  1|  2024-01-01|
# |  2|  2024-01-01|
# |  3|  2024-01-01|
# +---+------------+

Примечания

• Функция возвращает дату в формате 'yyyy-MM-dd'
• Для получения текущей даты и времени используйте current_timestamp()
• Для получения только времени используйте current_time()
• Для форматирования даты используйте date_format()