aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorvvvv <vvvv@yandex-team.ru>2022-03-14 16:23:46 +0300
committervvvv <vvvv@yandex-team.ru>2022-03-14 16:23:46 +0300
commit743003e05c206ec0ae9c2b21ae899a0de5158af6 (patch)
tree419ecfe07d30c1e8ed7e649833b6e28f07d469f9
parent09d5855347aeb13217d4bbdd9671630522173b64 (diff)
downloadydb-743003e05c206ec0ae9c2b21ae899a0de5158af6.tar.gz
YQL-13710 tune rowspec, llvm support in skiff codec
ref:b60e212107d7012e99515c3ae95dabe8387b483f
-rw-r--r--ydb/library/yql/parser/pg_wrapper/comp_factory.cpp8
-rw-r--r--ydb/library/yql/providers/common/codec/yql_pg_codec.h3
-rw-r--r--ydb/library/yql/providers/config/yql_config_provider.cpp3
-rw-r--r--ydb/library/yql/sql/pg_dummy/pg_sql_dummy.cpp14
4 files changed, 25 insertions, 3 deletions
diff --git a/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp b/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp
index daf3cf83839..a127160acf4 100644
--- a/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp
+++ b/ydb/library/yql/parser/pg_wrapper/comp_factory.cpp
@@ -1141,6 +1141,14 @@ void WriteSkiffPg(NKikimr::NMiniKQL::TPgType* type, const NKikimr::NUdf::TUnboxe
}
}
+extern "C" void ReadSkiffPgValue(NKikimr::NMiniKQL::TPgType* type, NKikimr::NUdf::TUnboxedValue& value, NCommon::TInputBuf& buf) {
+ value = ReadSkiffPg(type, buf);
+}
+
+extern "C" void WriteSkiffPgValue(NKikimr::NMiniKQL::TPgType* type, const NKikimr::NUdf::TUnboxedValuePod& value, NCommon::TOutputBuf& buf) {
+ WriteSkiffPg(type, value, buf);
+}
+
} // namespace NCommon
TMaybe<ui32> ConvertToPgType(NUdf::EDataSlot slot) {
diff --git a/ydb/library/yql/providers/common/codec/yql_pg_codec.h b/ydb/library/yql/providers/common/codec/yql_pg_codec.h
index 963d5231e14..b20adab166e 100644
--- a/ydb/library/yql/providers/common/codec/yql_pg_codec.h
+++ b/ydb/library/yql/providers/common/codec/yql_pg_codec.h
@@ -19,5 +19,8 @@ void WriteYsonValueInTableFormatPg(TOutputBuf& buf, NKikimr::NMiniKQL::TPgType*
NUdf::TUnboxedValue ReadYsonValuePg(NKikimr::NMiniKQL::TPgType* type, char cmd, TInputBuf& buf);
+extern "C" void ReadSkiffPgValue(NKikimr::NMiniKQL::TPgType* type, NKikimr::NUdf::TUnboxedValue& value, NCommon::TInputBuf& buf);
+extern "C" void WriteSkiffPgValue(NKikimr::NMiniKQL::TPgType* type, const NKikimr::NUdf::TUnboxedValuePod& value, NCommon::TOutputBuf& buf);
+
} // namespace NCommon
} // namespace NYql
diff --git a/ydb/library/yql/providers/config/yql_config_provider.cpp b/ydb/library/yql/providers/config/yql_config_provider.cpp
index 98e7fdced8d..3df2eba81c7 100644
--- a/ydb/library/yql/providers/config/yql_config_provider.cpp
+++ b/ydb/library/yql/providers/config/yql_config_provider.cpp
@@ -742,9 +742,6 @@ namespace {
}
Types.PgTypes = (name == "PgTypes");
- if (Types.PgTypes) {
- Types.OptLLVM = "OFF";
- }
}
else if (name == "FolderSubDirsLimit") {
if (args.size() != 1) {
diff --git a/ydb/library/yql/sql/pg_dummy/pg_sql_dummy.cpp b/ydb/library/yql/sql/pg_dummy/pg_sql_dummy.cpp
index bacf7064592..5fa30e60212 100644
--- a/ydb/library/yql/sql/pg_dummy/pg_sql_dummy.cpp
+++ b/ydb/library/yql/sql/pg_dummy/pg_sql_dummy.cpp
@@ -54,6 +54,20 @@ void WriteSkiffPg(NKikimr::NMiniKQL::TPgType* type, const NKikimr::NUdf::TUnboxe
throw yexception() << "PG types are not supported";
}
+extern "C" void ReadSkiffPgValue(NKikimr::NMiniKQL::TPgType* type, NKikimr::NUdf::TUnboxedValue& value, NCommon::TInputBuf& buf) {
+ Y_UNUSED(type);
+ Y_UNUSED(value);
+ Y_UNUSED(buf);
+ throw yexception() << "PG types are not supported";
+}
+
+extern "C" void WriteSkiffPgValue(NKikimr::NMiniKQL::TPgType* type, const NKikimr::NUdf::TUnboxedValuePod& value, NCommon::TOutputBuf& buf) {
+ Y_UNUSED(type);
+ Y_UNUSED(value);
+ Y_UNUSED(buf);
+ throw yexception() << "PG types are not supported";
+}
+
} // namespace NCommon
} // NYql