diff options
| author | nadya02 <nadya02@yandex-team.com> | 2023-09-14 13:48:29 +0300 |
|---|---|---|
| committer | nadya02 <nadya02@yandex-team.com> | 2023-09-14 14:05:05 +0300 |
| commit | eb28f232a306bce10b5d780659900d5e182116b8 (patch) | |
| tree | 58d6e9b538c281227756f6953c89474d18c63718 | |
| parent | 0f1f383f12c12532f1fc4f3bd4cf1697a3ed5fc4 (diff) | |
| download | ydb-eb28f232a306bce10b5d780659900d5e182116b8.tar.gz | |
YT-19430: Add arrow to http proxy
| -rw-r--r-- | yt/yt/client/formats/public.h | 1 | ||||
| -rw-r--r-- | yt/yt/library/formats/format.cpp | 9 |
2 files changed, 10 insertions, 0 deletions
diff --git a/yt/yt/client/formats/public.h b/yt/yt/client/formats/public.h index af572cc98f..cb258a5cfd 100644 --- a/yt/yt/client/formats/public.h +++ b/yt/yt/client/formats/public.h @@ -57,6 +57,7 @@ DEFINE_ENUM(EFormatType, (Protobuf) (WebJson) (Skiff) + (Arrow) ); //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/library/formats/format.cpp b/yt/yt/library/formats/format.cpp index 1b7e0cf749..1fdd5e3836 100644 --- a/yt/yt/library/formats/format.cpp +++ b/yt/yt/library/formats/format.cpp @@ -1,5 +1,6 @@ #include "format.h" +#include "arrow_writer.h" #include "dsv_parser.h" #include "dsv_writer.h" #include "protobuf_parser.h" @@ -314,6 +315,14 @@ ISchemalessFormatWriterPtr CreateStaticTableWriterForFormat( enableContextSaving, controlAttributesConfig, keyColumnCount); + case EFormatType::Arrow: + return CreateWriterForArrow( + nameTable, + tableSchemas, + std::move(output), + enableContextSaving, + controlAttributesConfig, + keyColumnCount); default: auto adapter = New<TSchemalessWriterAdapter>( nameTable, |