diff options
author | vvvv <vvvv@ydb.tech> | 2022-07-20 15:05:22 +0300 |
---|---|---|
committer | vvvv <vvvv@ydb.tech> | 2022-07-20 15:05:22 +0300 |
commit | 070dcb976b8e2c3f36068da9b27be329346b90a5 (patch) | |
tree | 6c52576bff8dc92d66955e76c6067dc5b371d480 | |
parent | 39d6f573778ab032b7d20202e32b955322a4bc3b (diff) | |
download | ydb-070dcb976b8e2c3f36068da9b27be329346b90a5.tar.gz |
pg support
-rw-r--r-- | ydb/library/yql/providers/common/codec/yql_codec.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/ydb/library/yql/providers/common/codec/yql_codec.cpp b/ydb/library/yql/providers/common/codec/yql_codec.cpp index 0e93780775f..83eb245c043 100644 --- a/ydb/library/yql/providers/common/codec/yql_codec.cpp +++ b/ydb/library/yql/providers/common/codec/yql_codec.cpp @@ -2173,6 +2173,8 @@ void WriteSkiffData(NKikimr::NMiniKQL::TType* type, ui64 nativeYtTypeFlags, cons void WriteSkiffNativeYtValue(NKikimr::NMiniKQL::TType* type, ui64 nativeYtTypeFlags, const NKikimr::NUdf::TUnboxedValuePod& value, NCommon::TOutputBuf& buf) { if (type->IsData()) { WriteSkiffData(type, nativeYtTypeFlags, value, buf); + } else if (type->IsPg()) { + WriteSkiffPgValue(static_cast<TPgType*>(type), value, buf); } else if (type->IsOptional()) { if (!value) { buf.Write('\0'); |