Initial suppoprt Timestamp64/Interval64 (#3445)

Tony-Romanov · web-flow · commit 4bcab8414b28 · 2024-04-04T17:39:52.000+02:00
diff --git a/ydb/core/engine/mkql_proto.cpp b/ydb/core/engine/mkql_proto.cpp
@@ -125,6 +125,10 @@ bool CellsFromTuple(const NKikimrMiniKQL::TType* tupleType,
         CASE_SIMPLE_TYPE(Datetime, ui32, Uint32);
         CASE_SIMPLE_TYPE(Timestamp, ui64, Uint64);
         CASE_SIMPLE_TYPE(Interval, i64, Int64);
+        CASE_SIMPLE_TYPE(Date32,   i32,  Int32);
+        CASE_SIMPLE_TYPE(Datetime64, i64, Int64);
+        CASE_SIMPLE_TYPE(Timestamp64, i64, Int64);
+        CASE_SIMPLE_TYPE(Interval64, i64, Int64);
 
 
 #undef CASE_SIMPLE_TYPE
@@ -228,6 +232,7 @@ bool CellToValue(NScheme::TTypeInfo type, const TCell& c, NKikimrMiniKQL::TValue
         val.MutableOptional()->SetUint32(ReadUnaligned<ui16>(c.Data()));
         break;
 
+    case NScheme::NTypeIds::Date32:
     case NScheme::NTypeIds::Int32:
         Y_ABORT_UNLESS(c.Size() == sizeof(i32));
         val.MutableOptional()->SetInt32(ReadUnaligned<i32>(c.Data()));
@@ -274,6 +279,9 @@ bool CellToValue(NScheme::TTypeInfo type, const TCell& c, NKikimrMiniKQL::TValue
         val.MutableOptional()->SetUint64(ReadUnaligned<ui64>(c.Data()));
         break;
     case NScheme::NTypeIds::Interval:
+    case NScheme::NTypeIds::Interval64:
+    case NScheme::NTypeIds::Timestamp64:
+    case NScheme::NTypeIds::Datetime64:
         Y_ABORT_UNLESS(c.Size() == sizeof(i64));
         val.MutableOptional()->SetInt64(ReadUnaligned<i64>(c.Data()));
         break;
diff --git a/ydb/core/formats/arrow/converter.cpp b/ydb/core/formats/arrow/converter.cpp
@@ -182,6 +182,15 @@ static std::shared_ptr<arrow::Array> InplaceConvertColumn(const std::shared_ptr<
             newData->type = arrow::timestamp(arrow::TimeUnit::MICRO);
             return std::make_shared<arrow::TimestampArray>(newData);
         }
+        case NScheme::NTypeIds::Timestamp64:
+        case NScheme::NTypeIds::Interval64: {
+            Y_ABORT_UNLESS(arrow::is_primitive(column->type()->id()));
+            Y_ABORT_UNLESS(arrow::bit_width(column->type()->id()) == 64);
+
+            auto newData = column->data()->Copy();
+            newData->type = arrow::int64();
+            return std::make_shared<arrow::NumericArray<arrow::Int64Type>>(newData);
+        }
         default:
             return {};
     }
@@ -231,6 +240,8 @@ bool TArrowToYdbConverter::NeedInplaceConversion(const NScheme::TTypeInfo& typeI
         case NScheme::NTypeIds::Datetime:
             return typeInRequest.GetTypeId() == NScheme::NTypeIds::Int32;
         case NScheme::NTypeIds::Timestamp:
+        case NScheme::NTypeIds::Timestamp64:
+        case NScheme::NTypeIds::Interval64:
             return typeInRequest.GetTypeId() == NScheme::NTypeIds::Int64;
         default:
             break;
diff --git a/ydb/core/formats/arrow/switch/switch_type.h b/ydb/core/formats/arrow/switch/switch_type.h
@@ -165,6 +165,10 @@ template <typename TFunc>
         case NScheme::NTypeIds::Decimal:
             return callback(TTypeWrapper<arrow::Decimal128Type>());
 
+        case NScheme::NTypeIds::Timestamp64:
+        case NScheme::NTypeIds::Interval64:
+            return callback(TTypeWrapper<arrow::Int64Type>());
+
         case NScheme::NTypeIds::PairUi64Ui64:
         case NScheme::NTypeIds::ActorId:
         case NScheme::NTypeIds::StepOrderId:
@@ -210,6 +214,8 @@ inline bool IsPrimitiveYqlType(const NScheme::TTypeInfo& typeInfo) {
         case NScheme::NTypeIds::Double:
         case NScheme::NTypeIds::Timestamp:
         case NScheme::NTypeIds::Interval:
+        case NScheme::NTypeIds::Timestamp64:
+        case NScheme::NTypeIds::Interval64:
             return true;
         default:
             break;
diff --git a/ydb/core/kqp/runtime/kqp_scan_data.cpp b/ydb/core/kqp/runtime/kqp_scan_data.cpp
@@ -45,6 +45,10 @@ TBytesStatistics GetUnboxedValueSize(const NUdf::TUnboxedValue& value, const NSc
         case NTypeIds::Datetime:
         case NTypeIds::Timestamp:
         case NTypeIds::Interval:
+        case NTypeIds::Date32:
+        case NTypeIds::Datetime64:
+        case NTypeIds::Timestamp64:
+        case NTypeIds::Interval64:
         case NTypeIds::ActorId:
         case NTypeIds::StepOrderId:
         {
@@ -330,11 +334,15 @@ TBytesStatistics WriteColumnValuesFromArrowImpl(TAccessor editAccessor,
         {
             return WriteColumnValuesFromArrowSpecImpl<TElementAccessor<arrow::Int16Array>>(editAccessor, batch, columnIndex, columnPtr, columnType);
         }
+        case NTypeIds::Date32:
         case NTypeIds::Int32:
         {
             return WriteColumnValuesFromArrowSpecImpl<TElementAccessor<arrow::Int32Array>>(editAccessor, batch, columnIndex, columnPtr, columnType);
         }
         case NTypeIds::Int64:
+        case NTypeIds::Timestamp64:
+        case NTypeIds::Interval64:
+        case NTypeIds::Datetime64:
         {
             return WriteColumnValuesFromArrowSpecImpl<TElementAccessor<arrow::Int64Array, i64>>(editAccessor, batch, columnIndex, columnPtr, columnType);
         }
diff --git a/ydb/core/kqp/ut/common/columnshard.cpp b/ydb/core/kqp/ut/common/columnshard.cpp
@@ -216,6 +216,10 @@ namespace NKqp {
             return arrow::field(name, arrow::timestamp(arrow::TimeUnit::TimeUnit::MICRO), nullable);
         case NScheme::NTypeIds::Interval:
             return arrow::field(name, arrow::duration(arrow::TimeUnit::TimeUnit::MICRO), nullable);
+        case NScheme::NTypeIds::Timestamp64:
+            return arrow::field(name, arrow::int64(), nullable);
+        case NScheme::NTypeIds::Interval64:
+            return arrow::field(name, arrow::int64(), nullable);
         case NScheme::NTypeIds::JsonDocument:
             return arrow::field(name, arrow::binary(), nullable);
         case NScheme::NTypeIds::Pg:
diff --git a/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp b/ydb/core/kqp/ut/scheme/kqp_scheme_ut.cpp
@@ -5559,6 +5559,34 @@ Y_UNIT_TEST_SUITE(KqpOlapScheme) {
         }
         testHelper.ReadData("SELECT * FROM `/Root/ColumnTableTest` WHERE id=1", "[[1;#;#;[\"test_res_1\"]]]");
     }
+
+    Y_UNIT_TEST(UseTime64Columns) {
+        TKikimrSettings runnerSettings;
+        runnerSettings.WithSampleTables = false;
+        TTestHelper testHelper(runnerSettings);
+
+        TVector<TTestHelper::TColumnSchema> schema = {
+            TTestHelper::TColumnSchema().SetName("id").SetType(NScheme::NTypeIds::Int32).SetNullable(false),
+            TTestHelper::TColumnSchema().SetName("interval").SetType(NScheme::NTypeIds::Interval64),
+            TTestHelper::TColumnSchema().SetName("timestamp").SetType(NScheme::NTypeIds::Timestamp64)
+        };
+
+        Tests::NCommon::TLoggerInit(testHelper.GetKikimr()).Initialize();
+        TTestHelper::TColumnTable testTable;
+
+        testTable.SetName("/Root/ColumnTableTest").SetPrimaryKey({"id"}).SetSharding({"id"}).SetSchema(schema);
+        testHelper.CreateTable(testTable);
+
+        {
+            TTestHelper::TUpdatesBuilder tableInserter(testTable.GetArrowSchema(schema));
+            tableInserter.AddRow().Add(1).Add(123).Add(-456);
+            tableInserter.AddRow().Add(2).Add(-789).AddNull();
+            testHelper.BulkUpsert(testTable, tableInserter);
+        }
+
+        testHelper.ReadData("SELECT * FROM `/Root/ColumnTableTest` WHERE id=1", "[[1;[123];[-456]]]");
+        testHelper.ReadData("SELECT * FROM `/Root/ColumnTableTest` WHERE id=2", "[[2;[-789];#]]");
+    }
 /*
     Y_UNIT_TEST(AddColumnOnSchemeChange) {
         TKikimrSettings runnerSettings;
diff --git a/ydb/core/local_pgwire/local_pgwire_util.cpp b/ydb/core/local_pgwire/local_pgwire_util.cpp
@@ -38,6 +38,14 @@ TString ColumnPrimitiveValueToString(NYdb::TValueParser& valueParser) {
             return valueParser.GetTimestamp().ToString();
         case NYdb::EPrimitiveType::Interval:
             return TStringBuilder() << valueParser.GetInterval();
+        case NYdb::EPrimitiveType::Date32:
+            return TStringBuilder() << valueParser.GetDate32();
+        case NYdb::EPrimitiveType::Datetime64:
+            return TStringBuilder() << valueParser.GetDatetime64();
+        case NYdb::EPrimitiveType::Timestamp64:
+            return TStringBuilder() << valueParser.GetTimestamp64();
+        case NYdb::EPrimitiveType::Interval64:
+            return TStringBuilder() << valueParser.GetInterval64();
         case NYdb::EPrimitiveType::TzDate:
             return valueParser.GetTzDate();
         case NYdb::EPrimitiveType::TzDatetime:
diff --git a/ydb/core/persqueue/type_codecs_defs.cpp b/ydb/core/persqueue/type_codecs_defs.cpp
@@ -70,6 +70,7 @@ TTypeCodecs::TTypeCodecs(TTypeId typeId) {
     AddCodec<TVarLenCodec<false>>();
 
     switch (typeId) {
+    case NTypeIds::Date32:
     case NTypeIds::Int32:
         AddFixedLen<TInt32>(this);
         AddIntCodecs<TInt32>(this);
@@ -79,6 +80,9 @@ TTypeCodecs::TTypeCodecs(TTypeId typeId) {
         AddIntCodecs<TUint32>(this);
         break;
     case NTypeIds::Int64:
+    case NTypeIds::Datetime64:
+    case NTypeIds::Timestamp64:
+    case NTypeIds::Interval64:
         AddFixedLen<TInt64>(this);
         AddIntCodecs<TInt64>(this);
         break;
diff --git a/ydb/core/scheme_types/scheme_type_registry.cpp b/ydb/core/scheme_types/scheme_type_registry.cpp
@@ -40,6 +40,8 @@ TTypeRegistry::TTypeRegistry()
     RegisterType<TInterval>();
     RegisterType<TDyNumber>();
     RegisterType<TUuid>();
+    RegisterType<TTimestamp64>();
+    RegisterType<TInterval64>();
 }
 
 void TTypeRegistry::CalculateMetadataEtag() {
diff --git a/ydb/core/scheme_types/scheme_types_defs.cpp b/ydb/core/scheme_types/scheme_types_defs.cpp
@@ -34,6 +34,8 @@ namespace NNames {
     DECLARE_TYPED_TYPE_NAME(Datetime);
     DECLARE_TYPED_TYPE_NAME(Timestamp);
     DECLARE_TYPED_TYPE_NAME(Interval);
+    DECLARE_TYPED_TYPE_NAME(Timestamp64);
+    DECLARE_TYPED_TYPE_NAME(Interval64);
 
     DECLARE_TYPED_TYPE_NAME(DyNumber);
     DECLARE_TYPED_TYPE_NAME(Uuid);
diff --git a/ydb/core/scheme_types/scheme_types_defs.h b/ydb/core/scheme_types/scheme_types_defs.h
@@ -243,12 +243,16 @@ namespace NNames {
     extern const char Datetime[9];
     extern const char Timestamp[10];
     extern const char Interval[9];
+    extern const char Timestamp64[12];
+    extern const char Interval64[11];
 }
 
 class TDate : public IIntegerTypeWithKeyString<ui16, NTypeIds::Date, NNames::Date> {};
 class TDatetime : public IIntegerTypeWithKeyString<ui32, NTypeIds::Datetime, NNames::Datetime> {};
 class TTimestamp : public IIntegerTypeWithKeyString<ui64, NTypeIds::Timestamp, NNames::Timestamp> {};
 class TInterval : public IIntegerTypeWithKeyString<i64, NTypeIds::Interval, NNames::Interval> {};
+class TTimestamp64 : public IIntegerTypeWithKeyString<i64, NTypeIds::Timestamp64, NNames::Timestamp64> {};
+class TInterval64 : public IIntegerTypeWithKeyString<i64, NTypeIds::Interval64, NNames::Interval64> {};
 
 #define KIKIMR_FOREACH_MINIKQL_TYPE_I(name, size, macro, ...) macro(name, T##name, __VA_ARGS__)
 
@@ -279,6 +283,8 @@ class TInterval : public IIntegerTypeWithKeyString<i64, NTypeIds::Interval, NNam
     xx(Interval, TInterval, __VA_ARGS__) \
     xx(DyNumber, TDyNumber, __VA_ARGS__) \
     xx(Uuid, TUuid, __VA_ARGS__) \
+    xx(Timestamp64, TTimestamp64, __VA_ARGS__) \
+    xx(Interval64, TInterval64, __VA_ARGS__) \
     /**/
 
 
diff --git a/ydb/core/tx/columnshard/columnshard_ut_common.cpp b/ydb/core/tx/columnshard/columnshard_ut_common.cpp
@@ -264,6 +264,7 @@ TCell MakeTestCell(const TTypeInfo& typeInfo, ui32 value, std::vector<TString>&
         const TString& str = mem.back();
         return TCell(str.data(), str.size());
     } else if (type == NTypeIds::Timestamp || type == NTypeIds::Interval ||
+                type == NTypeIds::Timestamp64 || type == NTypeIds::Interval64 ||
                 type == NTypeIds::Uint64 || type == NTypeIds::Int64) {
         return TCell::Make<ui64>(value);
     } else if (type == NTypeIds::Uint32 || type == NTypeIds::Int32 || type == NTypeIds::Datetime) {
diff --git a/ydb/core/tx/columnshard/engines/scheme/statistics/max/operator.h b/ydb/core/tx/columnshard/engines/scheme/statistics/max/operator.h
@@ -41,6 +41,8 @@ class TOperator: public IOperator {
             case NScheme::NTypeIds::Float:
             case NScheme::NTypeIds::Datetime:
             case NScheme::NTypeIds::Date:
+            case NScheme::NTypeIds::Timestamp64:
+            case NScheme::NTypeIds::Interval64:
                 return true;
             default:
                 break;
@@ -61,4 +63,4 @@ class TOperator: public IOperator {
     }
 };
 
-}
+}
diff --git a/ydb/core/tx/columnshard/engines/scheme/statistics/variability/operator.h b/ydb/core/tx/columnshard/engines/scheme/statistics/variability/operator.h
@@ -44,6 +44,8 @@ class TOperator: public IOperator {
             case NScheme::NTypeIds::Float:
             case NScheme::NTypeIds::Datetime:
             case NScheme::NTypeIds::Date:
+            case NScheme::NTypeIds::Timestamp64:
+            case NScheme::NTypeIds::Interval64:
                 return true;
             default:
                 break;
@@ -64,4 +66,4 @@ class TOperator: public IOperator {
     }
 };
 
-}
+}
diff --git a/ydb/core/tx/columnshard/transactions/operators/schema.h b/ydb/core/tx/columnshard/transactions/operators/schema.h
@@ -116,6 +116,8 @@ namespace NKikimr::NColumnShard {
             namespace NTypeIds = NScheme::NTypeIds;
             static const THashSet<NScheme::TTypeId> pkSupportedTypes = {
                 NTypeIds::Timestamp,
+                NTypeIds::Timestamp64,
+                NTypeIds::Interval64,
                 NTypeIds::Int8,
                 NTypeIds::Int16,
                 NTypeIds::Int32,
diff --git a/ydb/core/tx/columnshard/ut_rw/ut_columnshard_read_write.cpp b/ydb/core/tx/columnshard/ut_rw/ut_columnshard_read_write.cpp
@@ -1469,7 +1469,7 @@ void TestReadAggregate(const std::vector<NArrow::NTest::TTestColumn>& ydbSchema,
     THashSet<NScheme::TTypeId> intTypes = {
         NTypeIds::Int8, NTypeIds::Int16, NTypeIds::Int32, NTypeIds::Int64,
         NTypeIds::Uint8, NTypeIds::Uint16, NTypeIds::Uint32, NTypeIds::Uint64,
-        NTypeIds::Timestamp
+        NTypeIds::Timestamp, NTypeIds::Timestamp64, NTypeIds::Interval64
     };
     THashSet<NScheme::TTypeId> strTypes = {
         NTypeIds::Utf8, NTypeIds::String
diff --git a/ydb/core/tx/columnshard/ut_schema/ut_columnshard_schema.cpp b/ydb/core/tx/columnshard/ut_schema/ut_columnshard_schema.cpp
@@ -1158,7 +1158,9 @@ Y_UNIT_TEST_SUITE(TColumnShardTestSchema) {
             NTypeIds::Uint32,
             NTypeIds::Uint64,
             NTypeIds::Date,
-            NTypeIds::Datetime
+            NTypeIds::Datetime,
+            NTypeIds::Timestamp64,
+            NTypeIds::Interval64
         };
 
         auto schema = TTestSchema::YdbSchema(NArrow::NTest::TTestColumn("k0", TTypeInfo(NTypeIds::Timestamp)));
diff --git a/ydb/core/viewer/json_query.h b/ydb/core/viewer/json_query.h
@@ -255,7 +255,7 @@ class TJsonQuery : public TViewerPipeClient<TJsonQuery> {
 
 private:
     NJson::TJsonValue ColumnPrimitiveValueToJsonValue(NYdb::TValueParser& valueParser) {
-        switch (valueParser.GetPrimitiveType()) {
+        switch (const auto primitive = valueParser.GetPrimitiveType()) {
             case NYdb::EPrimitiveType::Bool:
                 return valueParser.GetBool();
             case NYdb::EPrimitiveType::Int8:
@@ -306,7 +306,8 @@ class TJsonQuery : public TViewerPipeClient<TJsonQuery> {
                 return valueParser.GetDyNumber();
             case NYdb::EPrimitiveType::Uuid:
                 return valueParser.GetUuid().ToString();
-        }
+            default:
+                Y_ENSURE(false, TStringBuilder() << "Unsupported type: " << primitive);        }
     }
 
     NJson::TJsonValue ColumnValueToJsonValue(NYdb::TValueParser& valueParser) {
diff --git a/ydb/core/ydb_convert/ydb_convert.cpp b/ydb/core/ydb_convert/ydb_convert.cpp
@@ -1154,6 +1154,10 @@ bool CellFromProtoVal(NScheme::TTypeInfo type, i32 typmod, const Ydb::Value* vp,
     EXTRACT_VAL(Datetime, uint32, ui32);
     EXTRACT_VAL(Timestamp, uint64, ui64);
     EXTRACT_VAL(Interval, int64, i64);
+    EXTRACT_VAL(Date32, int32, i32);
+    EXTRACT_VAL(Datetime64, int64, i64);
+    EXTRACT_VAL(Timestamp64, int64, i64);
+    EXTRACT_VAL(Interval64, int64, i64);
     case NScheme::NTypeIds::Json :
     case NScheme::NTypeIds::Utf8 : {
             TString v = val.Gettext_value();
@@ -1334,6 +1338,8 @@ void ProtoValueFromCell(NYdb::TValueBuilder& vb, const NScheme::TTypeInfo& typeI
     case EPrimitiveType::DyNumber:
         vb.DyNumber(getString());
         break;
+    default:
+        Y_ENSURE(false, TStringBuilder() << "Unsupported type: " << primitive);
     }
 }
 
diff --git a/ydb/library/backup/query_builder.cpp b/ydb/library/backup/query_builder.cpp
@@ -91,6 +91,7 @@ void TQueryBuilder::AddPrimitiveMember(EPrimitiveType type, TStringBuf buf) {
         break;
 
     case EPrimitiveType::Int32:
+    case EPrimitiveType::Date32:
         Value.Int32(TryParse<i32>(buf));
         break;
 
@@ -127,6 +128,9 @@ void TQueryBuilder::AddPrimitiveMember(EPrimitiveType type, TStringBuf buf) {
         break;
 
     case EPrimitiveType::Interval:
+    case EPrimitiveType::Datetime64:
+    case EPrimitiveType::Timestamp64:
+    case EPrimitiveType::Interval64:
         Value.Interval(TryParse<i64>(buf));
         break;
 
diff --git a/ydb/library/mkql_proto/mkql_proto.cpp b/ydb/library/mkql_proto/mkql_proto.cpp
@@ -825,6 +825,10 @@ void ExportPrimitiveTypeToProto(ui32 schemeType, Ydb::Type& output) {
         case NYql::NProto::TypeIds::Uuid:
         case NYql::NProto::TypeIds::JsonDocument:
         case NYql::NProto::TypeIds::DyNumber:
+        case NYql::NProto::TypeIds::Date32:
+        case NYql::NProto::TypeIds::Datetime64:
+        case NYql::NProto::TypeIds::Timestamp64:
+        case NYql::NProto::TypeIds::Interval64:
             output.set_type_id(static_cast<Ydb::Type::PrimitiveTypeId>(schemeType));
             break;
 
diff --git a/ydb/public/api/protos/ydb_value.proto b/ydb/public/api/protos/ydb_value.proto
@@ -83,6 +83,10 @@ message Type {
         TZ_DATE        = 0x0034;
         TZ_DATETIME    = 0x0035;
         TZ_TIMESTAMP   = 0x0036;
+        DATE32         = 0x0040;
+        DATETIME64     = 0x0041;
+        TIMESTAMP64    = 0x0042;
+        INTERVAL64     = 0x0043;
         STRING         = 0x1001;
         UTF8           = 0x1200;
         YSON           = 0x1201;
diff --git a/ydb/public/lib/yson_value/ydb_yson_value.cpp b/ydb/public/lib/yson_value/ydb_yson_value.cpp
@@ -55,6 +55,18 @@ static void PrimitiveValueToYson(EPrimitiveType type, TValueParser& parser, NYso
         case EPrimitiveType::Interval:
             writer.OnInt64Scalar(parser.GetInterval());
             break;
+        case EPrimitiveType::Date32:
+            writer.OnInt64Scalar(parser.GetDate32());
+            break;
+        case EPrimitiveType::Datetime64:
+            writer.OnInt64Scalar(parser.GetDatetime64());
+            break;
+        case EPrimitiveType::Timestamp64:
+            writer.OnInt64Scalar(parser.GetTimestamp64());
+            break;
+        case EPrimitiveType::Interval64:
+            writer.OnInt64Scalar(parser.GetInterval64());
+            break;
         case EPrimitiveType::TzDate:
             writer.OnStringScalar(parser.GetTzDate());
             break;
diff --git a/ydb/public/sdk/cpp/client/ydb_value/value.cpp b/ydb/public/sdk/cpp/client/ydb_value/value.cpp
diff --git a/ydb/public/sdk/cpp/client/ydb_value/value.h b/ydb/public/sdk/cpp/client/ydb_value/value.h
diff --git a/ydb/services/metadata/manager/ydb_value_operator.cpp b/ydb/services/metadata/manager/ydb_value_operator.cpp

Original file line number	Diff line number	Diff line change
`@@ -45,6 +45,10 @@ TBytesStatistics GetUnboxedValueSize(const NUdf::TUnboxedValue& value, const NSc`
`45`	`45`	`case NTypeIds::Datetime:`
`46`	`46`	`case NTypeIds::Timestamp:`
`47`	`47`	`case NTypeIds::Interval:`
	`48`	`+ case NTypeIds::Date32:`
	`49`	`+ case NTypeIds::Datetime64:`
	`50`	`+ case NTypeIds::Timestamp64:`
	`51`	`+ case NTypeIds::Interval64:`
`48`	`52`	`case NTypeIds::ActorId:`
`49`	`53`	`case NTypeIds::StepOrderId:`
`50`	`54`	`{`
`@@ -330,11 +334,15 @@ TBytesStatistics WriteColumnValuesFromArrowImpl(TAccessor editAccessor,`
`330`	`334`	`{`
`331`	`335`	`return WriteColumnValuesFromArrowSpecImpl<TElementAccessor<arrow::Int16Array>>(editAccessor, batch, columnIndex, columnPtr, columnType);`
`332`	`336`	`}`
	`337`	`+ case NTypeIds::Date32:`
`333`	`338`	`case NTypeIds::Int32:`
`334`	`339`	`{`
`335`	`340`	`return WriteColumnValuesFromArrowSpecImpl<TElementAccessor<arrow::Int32Array>>(editAccessor, batch, columnIndex, columnPtr, columnType);`
`336`	`341`	`}`
`337`	`342`	`case NTypeIds::Int64:`
	`343`	`+ case NTypeIds::Timestamp64:`
	`344`	`+ case NTypeIds::Interval64:`
	`345`	`+ case NTypeIds::Datetime64:`
`338`	`346`	`{`
`339`	`347`	`return WriteColumnValuesFromArrowSpecImpl<TElementAccessor<arrow::Int64Array, i64>>(editAccessor, batch, columnIndex, columnPtr, columnType);`
`340`	`348`	`}`
Original file line number	Diff line number	Diff line change
`@@ -40,6 +40,8 @@ TTypeRegistry::TTypeRegistry()`
`40`	`40`	`RegisterType<TInterval>();`
`41`	`41`	`RegisterType<TDyNumber>();`
`42`	`42`	`RegisterType<TUuid>();`
	`43`	`+ RegisterType<TTimestamp64>();`
	`44`	`+ RegisterType<TInterval64>();`
`43`	`45`	`}`
`44`	`46`
`45`	`47`	`void TTypeRegistry::CalculateMetadataEtag() {`