diff options
author | vvvv <vvvv@yandex-team.ru> | 2022-03-14 16:23:46 +0300 |
---|---|---|
committer | vvvv <vvvv@yandex-team.ru> | 2022-03-14 16:23:46 +0300 |
commit | 743003e05c206ec0ae9c2b21ae899a0de5158af6 (patch) | |
tree | 419ecfe07d30c1e8ed7e649833b6e28f07d469f9 | |
parent | 09d5855347aeb13217d4bbdd9671630522173b64 (diff) | |
download | ydb-743003e05c206ec0ae9c2b21ae899a0de5158af6.tar.gz |
YQL-13710 tune rowspec, llvm support in skiff codec
ref:b60e212107d7012e99515c3ae95dabe8387b483f
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 |