summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/common.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/interface/common.cpp')
-rw-r--r--yt/cpp/mapreduce/interface/common.cpp27
1 files changed, 27 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/common.cpp b/yt/cpp/mapreduce/interface/common.cpp
index 28f98713f68..0a46c0b583a 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);
}