Support date type in SubstraitToVeloxPlan and hash function (#96)

Author: PHILO-HE

velox/functions/sparksql/Hash.cpp

@@ -106,6 +106,10 @@ uint32_t hashDouble(double input, uint32_t seed) {
       input == -0. ? 0 : *reinterpret_cast<uint64_t*>(&input), seed);
 }
 
+uint32_t hashDate(Date input, uint32_t seed) {
+  return hashInt32(input.days(), seed);
+}
+
 class HashFunction final : public exec::VectorFunction {
   bool isDefaultNullBehavior() const final {
     return false;
@@ -154,6 +158,7 @@ class HashFunction final : public exec::VectorFunction {
         CASE(VARBINARY, hashBytes, StringView);
         CASE(REAL, hashFloat, float);
         CASE(DOUBLE, hashDouble, double);
+        CASE(DATE, hashDate, int32_t);
 #undef CASE
         default:
           VELOX_NYI("Unsupported type for HASH(): {}", arg->type()->toString());

velox/substrait/SubstraitToVeloxPlan.cpp

@@ -1615,6 +1615,13 @@ void SubstraitVeloxPlanConverter::setFilterMap(
       setColInfoMap<std::string>(
           functionName, colIdxVal, val, reverse, colInfoMap);
       break;
+    case TypeKind::DATE:
+      if (substraitLit) {
+        val = variant(Date(substraitLit.value().date()));
+      }
+      setColInfoMap<int>(
+          functionName, colIdxVal, val, reverse, colInfoMap);
+      break;
     default:
       VELOX_NYI(
           "Subfield filters creation not supported for input type '{}'",
@@ -1892,6 +1899,10 @@ connector::hive::SubfieldFilters SubstraitVeloxPlanConverter::mapToFilters(
         constructSubfieldFilters<TypeKind::VARCHAR, common::Filter>(
             colIdx, inputNameList[colIdx], colInfoMap[colIdx], filters);
         break;
+      case TypeKind::DATE:
+        constructSubfieldFilters<TypeKind::DATE, common::BigintRange>(
+            colIdx, inputNameList[colIdx], colInfoMap[colIdx], filters);
+        break;
       default:
         VELOX_NYI(
             "Subfield filters creation not supported for input type '{}'",

velox/substrait/SubstraitToVeloxPlanValidator.cpp

@@ -336,13 +336,8 @@ bool SubstraitToVeloxPlanValidator::validate(
     return false;
   }
 
-  // In velox, the supported hash type in projectNode is
-  // BOOLEAN, TINYINT, SMALLINT, INTEGER, BIGINT, VARCHAR, VARBINARY
-  // REAL, DOUBLE. Hash.cpp (L148 - L156)
   for (auto i = 0; i < types.size(); i++) {
     switch (types[i]->kind()) {
-      case TypeKind::DATE:
-        return false;
       case TypeKind::ARRAY:
         return false;
       default:;

velox/substrait/TypeUtils.h

@@ -60,6 +60,13 @@ struct RangeTraits<TypeKind::VARCHAR> {
   using NativeType = std::string;
 };
 
+template <>
+struct RangeTraits<TypeKind::DATE> {
+  using RangeType = common::BigintRange;
+  using MultiRangeType = common::BigintMultiRange;
+  using NativeType = int32_t;
+};
+
 #endif /* RANGETRAITS_H */
 
 } // namespace facebook::velox::substrait