YT-18458: Introduce wide types into mapreduce interface

7ae047ef618cc44d7dd3e817dc27f2336d9e38c3

1 files changed, 27 insertions, 0 deletions

diff --git a/yt/cpp/mapreduce/interface/common.cpp b/yt/cpp/mapreduce/interface/common.cpp
index 28f98713f6..0a46c0b583 100644
--- a/yt/cpp/mapreduce/interface/common.cpp
+++ b/yt/cpp/mapreduce/interface/common.cpp
@@ -192,6 +192,15 @@ static NTi::TTypePtr OldTypeToTypeV3(EValueType type)
             return NTi::Float();
         case VT_JSON:
             return NTi::Json();
+
+        case VT_DATE32:
+            return NTi::Date32();
+        case VT_DATETIME64:
+            return NTi::Datetime64();
+        case VT_TIMESTAMP64:
+            return NTi::Timestamp64();
+        case VT_INTERVAL64:
+            return NTi::Interval64();
     }
 }
 
@@ -254,6 +263,15 @@ static std::pair<EValueType, bool> Simplify(const NTi::TTypePtr& type)
         case ETypeName::Yson:
             return {VT_ANY, true};
 
+        case ETypeName::Date32:
+            return {VT_DATE32, true};
+        case ETypeName::Datetime64:
+            return {VT_DATETIME64, true};
+        case ETypeName::Timestamp64:
+            return {VT_TIMESTAMP64, true};
+        case ETypeName::Interval64:
+            return {VT_INTERVAL64, true};
+
         case ETypeName::Void:
             return {VT_VOID, false};
         case ETypeName::Null:
@@ -633,6 +651,15 @@ TString ToString(EValueType type)
 
         case VT_JSON:
             return "json";
+
+        case VT_DATE32:
+            return "date32";
+        case VT_DATETIME64:
+            return "datetime64";
+        case VT_TIMESTAMP64:
+            return "timestamp64";
+        case VT_INTERVAL64:
+            return "interval64";
     }
     ythrow yexception() << "Invalid value type " << static_cast<int>(type);
 }