feat(flink): implement support for UUID literals

ibis/backends/flink/utils.py

@@ -4,14 +4,12 @@
 import math
 from abc import ABC, abstractmethod
 from collections import defaultdict
-from typing import TYPE_CHECKING
 
+import ibis.expr.datatypes as dt
+import ibis.expr.operations as ops
 from ibis.common.temporal import IntervalUnit
 from ibis.util import convert_unit
 
-if TYPE_CHECKING:
-    import ibis.expr.operations as ops
-
 # For details on what precisions Flink SQL interval types support, see
 # https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/types/#interval-year-to-month
 # https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/types/#interval-day-to-second
@@ -284,4 +282,6 @@ def translate_literal(op: ops.Literal) -> str:
         return f"TIME '{value}'"
     elif dtype.is_interval():
         return f"INTERVAL {_translate_interval(value, dtype)}"
+    elif dtype.is_uuid():
+        return translate_literal(ops.Literal(str(value), dtype=dt.str))
     raise NotImplementedError(f"No translation rule for {dtype}")

ibis/backends/tests/test_uuid.py

@@ -23,6 +23,7 @@
     "snowflake": "VARCHAR",
     "trino": "varchar(32)" if SQLALCHEMY2 else "uuid",
     "postgres": "uuid",
+    "flink": "CHAR(36) NOT NULL",
 }
 
 UUID_EXPECTED_VALUES = {
@@ -37,6 +38,7 @@
     "mssql": TEST_UUID,
     "dask": TEST_UUID,
     "oracle": TEST_UUID,
+    "flink": TEST_UUID,
 }
 
 pytestmark = pytest.mark.notimpl(