Skip to content

Commit 7a4c2f7

Browse files
authored
Merge output tables (#14446)
1 parent 8b46b94 commit 7a4c2f7

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

ydb/tools/query_replay_yt/main.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -286,5 +286,13 @@ int main(int argc, const char** argv) {
286286

287287
client->Map(spec, new TQueryReplayMapper(config.UdfFiles, config.ActorSystemThreadsCount, config.EnableAntlr4Parser, config.YqlLogLevel));
288288

289+
auto mergeSpec = NYT::TMergeOperationSpec();
290+
mergeSpec.AddInput(NYT::TRichYPath(config.DstPath));
291+
mergeSpec.Output(NYT::TRichYPath(config.DstPath));
292+
mergeSpec.CombineChunks(true);
293+
mergeSpec.ForceTransform(true);
294+
295+
client->Merge(mergeSpec);
296+
289297
return EXIT_SUCCESS;
290298
}

0 commit comments

Comments
 (0)