37 lines
1.3 KiB
Python
37 lines
1.3 KiB
Python
|
from __future__ import annotations
|
||
|
|
|
||
|
|
from functools import partial
|
||
|
|
from typing import TYPE_CHECKING
|
||
|
|
|
||
|
|
from narwhals._spark_like.utils import strptime_to_pyspark_format
|
||
|
|
from narwhals._sql.expr_str import SQLExprStringNamespace
|
||
|
|
from narwhals._utils import _is_naive_format, not_implemented
|
||
|
|
|
||
|
|
if TYPE_CHECKING:
|
||
|
|
from narwhals._spark_like.expr import SparkLikeExpr
|
||
|
|
|
||
|
|
|
||
|
|
class SparkLikeExprStringNamespace(SQLExprStringNamespace["SparkLikeExpr"]):
|
||
|
|
def to_datetime(self, format: str | None) -> SparkLikeExpr:
|
||
|
|
F = self.compliant._F
|
||
|
|
if not format:
|
||
|
|
function = F.to_timestamp
|
||
|
|
elif _is_naive_format(format):
|
||
|
|
function = partial(
|
||
|
|
F.to_timestamp_ntz, format=F.lit(strptime_to_pyspark_format(format))
|
||
|
|
)
|
||
|
|
else:
|
||
|
|
format = strptime_to_pyspark_format(format)
|
||
|
|
function = partial(F.to_timestamp, format=format)
|
||
|
|
return self.compliant._with_elementwise(
|
||
|
|
lambda expr: function(F.replace(expr, F.lit("T"), F.lit(" ")))
|
||
|
|
)
|
||
|
|
|
||
|
|
def to_date(self, format: str | None) -> SparkLikeExpr:
|
||
|
|
F = self.compliant._F
|
||
|
|
return self.compliant._with_elementwise(
|
||
|
|
lambda expr: F.to_date(expr, format=strptime_to_pyspark_format(format))
|
||
|
|
)
|
||
|
|
|
||
|
|
replace = not_implemented()
|