google
diff --git a/‎bigframes/core/col.py‎
Lines changed: 51 additions & 28 deletions b/‎bigframes/core/col.py‎
Lines changed: 51 additions & 28 deletions
diff --git a/‎bigframes/core/compile/ibis_compiler/scalar_op_registry.py‎
Lines changed: 3 additions & 1 deletion b/‎bigframes/core/compile/ibis_compiler/scalar_op_registry.py‎
Lines changed: 3 additions & 1 deletion
diff --git a/‎bigframes/operations/datetime_ops.py‎
Lines changed: 3 additions & 0 deletions b/‎bigframes/operations/datetime_ops.py‎
Lines changed: 3 additions & 0 deletions
@@ -14,7 +14,7 @@
 from __future__ import annotations
 
 import dataclasses
-from typing import Any, Hashable
+from typing import Any, Hashable, Literal, TYPE_CHECKING
 
 import bigframes_vendored.pandas.core.col as pd_col
 
@@ -23,6 +23,10 @@
 import bigframes.operations as bf_ops
 import bigframes.operations.aggregations as agg_ops
 
+if TYPE_CHECKING:
+    import bigframes.operations.datetimes as datetimes
+    import bigframes.operations.strings as strings
+
 
 # Not to be confused with the Expression class in `bigframes.core.expressions`
 # Name collision unintended
@@ -32,7 +36,7 @@ class Expression:
 
     _value: bf_expression.Expression
 
-    def _apply_unary(self, op: bf_ops.UnaryOp) -> Expression:
+    def _apply_unary_op(self, op: bf_ops.UnaryOp) -> Expression:
         return Expression(op.as_expr(self._value))
 
     def _apply_unary_agg(self, op: agg_ops.UnaryAggregateOp) -> Expression:
@@ -44,7 +48,14 @@ def _apply_unary_agg(self, op: agg_ops.UnaryAggregateOp) -> Expression:
             agg_expressions.WindowExpression(agg_expr, window_spec.unbound())
         )
 
-    def _apply_binary(self, other: Any, op: bf_ops.BinaryOp, reverse: bool = False):
+    # alignment is purely for series compatibility, and is ignored here
+    def _apply_binary_op(
+        self,
+        other: Any,
+        op: bf_ops.BinaryOp,
+        alignment: Literal["outer", "left"] = "outer",
+        reverse: bool = False,
+    ):
         if isinstance(other, Expression):
             other_value = other._value
         else:
@@ -55,79 +66,79 @@ def _apply_binary(self, other: Any, op: bf_ops.BinaryOp, reverse: bool = False):
             return Expression(op.as_expr(self._value, other_value))
 
     def __add__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.add_op)
+        return self._apply_binary_op(other, bf_ops.add_op)
 
     def __radd__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.add_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.add_op, reverse=True)
 
     def __sub__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.sub_op)
+        return self._apply_binary_op(other, bf_ops.sub_op)
 
     def __rsub__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.sub_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.sub_op, reverse=True)
 
     def __mul__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.mul_op)
+        return self._apply_binary_op(other, bf_ops.mul_op)
 
     def __rmul__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.mul_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.mul_op, reverse=True)
 
     def __truediv__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.div_op)
+        return self._apply_binary_op(other, bf_ops.div_op)
 
     def __rtruediv__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.div_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.div_op, reverse=True)
 
     def __floordiv__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.floordiv_op)
+        return self._apply_binary_op(other, bf_ops.floordiv_op)
 
     def __rfloordiv__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.floordiv_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.floordiv_op, reverse=True)
 
     def __ge__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.ge_op)
+        return self._apply_binary_op(other, bf_ops.ge_op)
 
     def __gt__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.gt_op)
+        return self._apply_binary_op(other, bf_ops.gt_op)
 
     def __le__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.le_op)
+        return self._apply_binary_op(other, bf_ops.le_op)
 
     def __lt__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.lt_op)
+        return self._apply_binary_op(other, bf_ops.lt_op)
 
     def __eq__(self, other: object) -> Expression:  # type: ignore
-        return self._apply_binary(other, bf_ops.eq_op)
+        return self._apply_binary_op(other, bf_ops.eq_op)
 
     def __ne__(self, other: object) -> Expression:  # type: ignore
-        return self._apply_binary(other, bf_ops.ne_op)
+        return self._apply_binary_op(other, bf_ops.ne_op)
 
     def __mod__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.mod_op)
+        return self._apply_binary_op(other, bf_ops.mod_op)
 
     def __rmod__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.mod_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.mod_op, reverse=True)
 
     def __and__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.and_op)
+        return self._apply_binary_op(other, bf_ops.and_op)
 
     def __rand__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.and_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.and_op, reverse=True)
 
     def __or__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.or_op)
+        return self._apply_binary_op(other, bf_ops.or_op)
 
     def __ror__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.or_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.or_op, reverse=True)
 
     def __xor__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.xor_op)
+        return self._apply_binary_op(other, bf_ops.xor_op)
 
     def __rxor__(self, other: Any) -> Expression:
-        return self._apply_binary(other, bf_ops.xor_op, reverse=True)
+        return self._apply_binary_op(other, bf_ops.xor_op, reverse=True)
 
     def __invert__(self) -> Expression:
-        return self._apply_unary(bf_ops.invert_op)
+        return self._apply_unary_op(bf_ops.invert_op)
 
     def sum(self) -> Expression:
         return self._apply_unary_agg(agg_ops.sum_op)
@@ -147,6 +158,18 @@ def min(self) -> Expression:
     def max(self) -> Expression:
         return self._apply_unary_agg(agg_ops.max_op)
 
+    @property
+    def dt(self) -> datetimes.DatetimeSimpleMethods:
+        import bigframes.operations.datetimes as datetimes
+
+        return datetimes.DatetimeSimpleMethods(self)
+
+    @property
+    def str(self) -> strings.StringMethods:
+        import bigframes.operations.strings as strings
+
+        return strings.StringMethods(self)
+
 
 def col(col_name: Hashable) -> Expression:
     return Expression(bf_expression.free_var(col_name))
 
@@ -982,7 +982,9 @@ def isin_op_impl(x: ibis_types.Value, op: ops.IsInOp):
 
 @scalar_op_compiler.register_unary_op(ops.ToDatetimeOp, pass_op=True)
 def to_datetime_op_impl(x: ibis_types.Value, op: ops.ToDatetimeOp):
-    if x.type() in (ibis_dtypes.str, ibis_dtypes.Timestamp("UTC")):  # type: ignore
+    if x.type() == ibis_dtypes.Timestamp(None):  # type: ignore
+        return x  # already a timestamp, no-op
+    elif x.type() in (ibis_dtypes.str, ibis_dtypes.Timestamp("UTC")):  # type: ignore
         return x.try_cast(ibis_dtypes.Timestamp(None))  # type: ignore
     else:
         # Numerical inputs.
 
@@ -74,6 +74,7 @@ def output_type(self, *input_types: dtypes.ExpressionType) -> dtypes.ExpressionT
             dtypes.STRING_DTYPE,
             dtypes.DATE_DTYPE,
             dtypes.TIMESTAMP_DTYPE,
+            dtypes.DATETIME_DTYPE,
         ):
             raise TypeError("expected string or numeric input")
         return pd.ArrowDtype(pa.timestamp("us", tz=None))
@@ -87,6 +88,8 @@ class ToTimestampOp(base_ops.UnaryOp):
 
     def output_type(self, *input_types: dtypes.ExpressionType) -> dtypes.ExpressionType:
         # Must be numeric or string
+        if input_types[0] == dtypes.TIMESTAMP_DTYPE:
+            raise TypeError("Already tz-aware.")
         if input_types[0] not in (
             dtypes.FLOAT_DTYPE,
             dtypes.INT_DTYPE,