Skip to content

current_date()

Описание

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

Параметры

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

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

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

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

from pyspark.sql import SparkSession
from pyspark.sql.functions import current_date

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

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

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

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

Примечания

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