diff options
| author | Vitalii Gridnev <gridnevvvit@gmail.com> | 2025-02-11 17:09:24 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-02-11 14:09:24 +0000 |
| commit | 7a4c2f7e40790497b5140c5930d4959774b2670c (patch) | |
| tree | c855904a015e08d048d212313afca26292cb6d6c | |
| parent | 8b46b949606db9cad38219172be751a7eda99007 (diff) | |
| download | ydb-7a4c2f7e40790497b5140c5930d4959774b2670c.tar.gz | |
Merge output tables (#14446)
| -rw-r--r-- | ydb/tools/query_replay_yt/main.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/ydb/tools/query_replay_yt/main.cpp b/ydb/tools/query_replay_yt/main.cpp index f0396fb21b..ec09c574ee 100644 --- a/ydb/tools/query_replay_yt/main.cpp +++ b/ydb/tools/query_replay_yt/main.cpp @@ -286,5 +286,13 @@ int main(int argc, const char** argv) { client->Map(spec, new TQueryReplayMapper(config.UdfFiles, config.ActorSystemThreadsCount, config.EnableAntlr4Parser, config.YqlLogLevel)); + auto mergeSpec = NYT::TMergeOperationSpec(); + mergeSpec.AddInput(NYT::TRichYPath(config.DstPath)); + mergeSpec.Output(NYT::TRichYPath(config.DstPath)); + mergeSpec.CombineChunks(true); + mergeSpec.ForceTransform(true); + + client->Merge(mergeSpec); + return EXIT_SUCCESS; } |