По умолчанию спарк использует формат yyyy-MM-dd
для типа даты.
, если вы хотите, чтобы формат MM/dd/YYYY
был date type
, тогда это невозможно с искрой (нулевое значение результатов).
Example:
Converting MM/dd/YYYY to date type:
scala> spark.sql("select date('01/01/1990') as dt").show()
//+----+
//| dt|
//+----+
//|null| //result null
//+----+
scala> spark.sql("select date('01/01/1990') as dt").printSchema
//root
//|-- dt: date (nullable = true)
Converting YYYY-MM-dd to date type:
scala> spark.sql("select date('1990-01-01') as dt").show(false)
//+----------+
//|dt |
//+----------+
//|1990-01-01| //results data
//+----------+
scala> spark.sql("select date('1990-01-01') as dt").printSchema
//root
// |-- dt: date (nullable = true)