diff options
| author | robot-piglet <robot-piglet@yandex-team.com> | 2023-10-03 22:30:37 +0300 |
|---|---|---|
| committer | robot-piglet <robot-piglet@yandex-team.com> | 2023-10-03 22:47:57 +0300 |
| commit | 4275724293f2729fd92a2d2ea602e82c0237d283 (patch) | |
| tree | 64394ebdb7b29249a9c40af68ad05763e528c236 /yt | |
| parent | 50d9f0da6a8c9a0b5b52469ffb1980281a74ef8a (diff) | |
| download | ydb-4275724293f2729fd92a2d2ea602e82c0237d283.tar.gz | |
Intermediate changes
Diffstat (limited to 'yt')
| -rw-r--r-- | yt/yt/client/driver/table_commands.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/yt/yt/client/driver/table_commands.cpp b/yt/yt/client/driver/table_commands.cpp index c211b79111..f49ed631ef 100644 --- a/yt/yt/client/driver/table_commands.cpp +++ b/yt/yt/client/driver/table_commands.cpp @@ -113,8 +113,9 @@ void TReadTableCommand::DoExecute(ICommandContextPtr context) return; } + auto format = context->GetOutputFormat(); auto writer = CreateStaticTableWriterForFormat( - context->GetOutputFormat(), + format, reader->GetNameTable(), {reader->GetTableSchema()}, context->Request().OutputStream, @@ -135,8 +136,10 @@ void TReadTableCommand::DoExecute(ICommandContextPtr context) }); TRowBatchReadOptions options{ - .MaxRowsPerRead = context->GetConfig()->ReadBufferRowCount + .MaxRowsPerRead = context->GetConfig()->ReadBufferRowCount, + .Columnar = (format.GetType() == EFormatType::Arrow) }; + PipeReaderToWriterByBatches( reader, writer, |