aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorvvvv <vvvv@ydb.tech>2022-07-20 15:05:22 +0300
committervvvv <vvvv@ydb.tech>2022-07-20 15:05:22 +0300
commit070dcb976b8e2c3f36068da9b27be329346b90a5 (patch)
tree6c52576bff8dc92d66955e76c6067dc5b371d480
parent39d6f573778ab032b7d20202e32b955322a4bc3b (diff)
downloadydb-070dcb976b8e2c3f36068da9b27be329346b90a5.tar.gz
pg support
-rw-r--r--ydb/library/yql/providers/common/codec/yql_codec.cpp2
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');