diff --git a/velox/functions/prestosql/UuidFunctions.h b/velox/functions/prestosql/UuidFunctions.h index 9e4b319a7fff..4da630e986f2 100644 --- a/velox/functions/prestosql/UuidFunctions.h +++ b/velox/functions/prestosql/UuidFunctions.h @@ -20,10 +20,29 @@ #include "velox/functions/Macros.h" #include "velox/functions/Registerer.h" +#include "velox/functions/prestosql/Comparisons.h" #include "velox/functions/prestosql/types/UuidType.h" namespace facebook::velox::functions { +#define VELOX_GEN_BINARY_EXPR_UUID(Name, uuidCompExpr) \ + template \ + struct Name##Uuid { \ + VELOX_DEFINE_FUNCTION_TYPES(T); \ + \ + FOLLY_ALWAYS_INLINE void \ + call(bool& result, const arg_type& lhs, const arg_type& rhs) { \ + result = (uuidCompExpr); \ + } \ + }; + +VELOX_GEN_BINARY_EXPR_UUID(LtFunction, (uint128_t)lhs < (uint128_t)rhs); +VELOX_GEN_BINARY_EXPR_UUID(GtFunction, (uint128_t)lhs > (uint128_t)rhs); +VELOX_GEN_BINARY_EXPR_UUID(LteFunction, (uint128_t)lhs <= (uint128_t)rhs); +VELOX_GEN_BINARY_EXPR_UUID(GteFunction, (uint128_t)lhs >= (uint128_t)rhs); + +#undef VELOX_GEN_BINARY_EXPR_UUID + template struct UuidFunction { VELOX_DEFINE_FUNCTION_TYPES(T); @@ -42,6 +61,10 @@ struct UuidFunction { inline void registerUuidFunctions(const std::string& prefix) { registerUuidType(); registerFunction({prefix + "uuid"}); + registerFunction({prefix + "lt"}); + registerFunction({prefix + "gt"}); + registerFunction({prefix + "lte"}); + registerFunction({prefix + "gte"}); } } // namespace facebook::velox::functions diff --git a/velox/functions/prestosql/tests/UuidFunctionsTest.cpp b/velox/functions/prestosql/tests/UuidFunctionsTest.cpp index 4fc636d966f3..6afbe2b82747 100644 --- a/velox/functions/prestosql/tests/UuidFunctionsTest.cpp +++ b/velox/functions/prestosql/tests/UuidFunctionsTest.cpp @@ -108,5 +108,119 @@ TEST_F(UuidFunctionsTest, unsupportedCast) { evaluate("cast(123 as uuid())", input), "Cannot cast BIGINT to UUID."); } +TEST_F(UuidFunctionsTest, comparisons) { + const auto uuidEval = [&](const std::optional& lhs, + const std::string& operation, + const std::optional& rhs) { + return evaluateOnce( + fmt::format("cast(c0 as uuid) {} cast(c1 as uuid)", operation), + lhs, + rhs); + }; + + ASSERT_EQ( + true, + uuidEval( + "33355449-2c7d-43d7-967a-f53cd23215ad", + "<", + "ffffffff-ffff-ffff-ffff-ffffffffffff")); + ASSERT_EQ( + false, + uuidEval( + "33355449-2c7d-43d7-967a-f53cd23215ad", + "<", + "00000000-0000-0000-0000-000000000000")); + ASSERT_EQ( + true, + uuidEval( + "f768f36d-4f09-4da7-a298-3564d8f3c986", + ">", + "00000000-0000-0000-0000-000000000000")); + ASSERT_EQ( + false, + uuidEval( + "f768f36d-4f09-4da7-a298-3564d8f3c986", + ">", + "ffffffff-ffff-ffff-ffff-ffffffffffff")); + + ASSERT_EQ( + true, + uuidEval( + "33355449-2c7d-43d7-967a-f53cd23215ad", + "<=", + "33355449-2c7d-43d7-967a-f53cd23215ad")); + ASSERT_EQ( + true, + uuidEval( + "33355449-2c7d-43d7-967a-f53cd23215ad", + "<=", + "ffffffff-ffff-ffff-ffff-ffffffffffff")); + ASSERT_EQ( + true, + uuidEval( + "33355449-2c7d-43d7-967a-f53cd23215ad", + ">=", + "33355449-2c7d-43d7-967a-f53cd23215ad")); + ASSERT_EQ( + true, + uuidEval( + "ffffffff-ffff-ffff-ffff-ffffffffffff", + ">=", + "33355449-2c7d-43d7-967a-f53cd23215ad")); + + ASSERT_EQ( + true, + uuidEval( + "f768f36d-4f09-4da7-a298-3564d8f3c986", + "==", + "f768f36d-4f09-4da7-a298-3564d8f3c986")); + ASSERT_EQ( + true, + uuidEval( + "eed9f812-4b0c-472f-8a10-4ae7bff79a47", + "!=", + "f768f36d-4f09-4da7-a298-3564d8f3c986")); + + ASSERT_EQ( + true, + uuidEval( + "11000000-0000-0022-0000-000000000000", + "<", + "22000000-0000-0011-0000-000000000000")); + ASSERT_EQ( + true, + uuidEval( + "00000000-0000-0000-2200-000000000011", + ">", + "00000000-0000-0000-1100-000000000022")); + ASSERT_EQ( + false, + uuidEval( + "00000000-0000-0000-0000-000000000011", + ">", + "22000000-0000-0000-0000-000000000000")); + ASSERT_EQ( + false, + uuidEval( + "11000000-0000-0000-0000-000000000000", + "<", + "00000000-0000-0000-0000-000000000022")); + + std::string lhs = "12342345-3456-4567-5678-678978908901"; + std::string rhs = "23451234-4567-3456-6789-567889017890"; + ASSERT_EQ(true, uuidEval(lhs, "<", rhs)); + + for (vector_size_t i = 0; i < lhs.size(); i++) { + if (lhs[i] == '-') { + continue; + } + lhs[i] = '0'; + rhs[i] = '0'; + bool expected = boost::lexical_cast(lhs) < + boost::lexical_cast(rhs); + ASSERT_EQ(expected, uuidEval(lhs, "<", rhs)); + } +} + } // namespace } // namespace facebook::velox::functions::prestosql