Query replay with coredumps (#7862)

Author: shnikd

ydb/tools/query_replay_yt/main.cpp

@@ -277,6 +277,9 @@ int main(int argc, const char** argv) {
     }
 
     spec.MapperSpec(userJobSpec);
+    if (!config.CoreTablePath.empty()) {
+        spec.CoreTablePath(config.CoreTablePath);
+    }
 
     client->Map(spec, new TQueryReplayMapper(config.UdfFiles, config.ActorSystemThreadsCount, config.YqlLogLevel));
 

ydb/tools/query_replay_yt/query_replay.cpp

@@ -17,6 +17,7 @@ void TQueryReplayConfig::ParseConfig(int argc, const char** argv) {
     opts.AddLongOption("cluster", "YT cluster").StoreResult(&Cluster);
     opts.AddLongOption("src-path", "Source table path").StoreResult(&SrcPath);
     opts.AddLongOption("dst-path", "Target table path").StoreResult(&DstPath);
+    opts.AddLongOption("core-table-path", "Core table path").StoreResult(&CoreTablePath);
     opts.AddLongOption("threads", "Number of ActorSystem threads").StoreResult(&ActorSystemThreadsCount);
     opts.AddLongOption("udf-file", "UDFS to load").AppendTo(&UdfFiles);
     opts.AddLongOption("query", "Single query to replay").StoreResult(&QueryFile);

ydb/tools/query_replay_yt/query_replay.h

@@ -17,6 +17,7 @@ struct TQueryReplayConfig {
     TString Cluster;
     TString SrcPath;
     TString DstPath;
+    TString CoreTablePath;
     ui32 ActorSystemThreadsCount = 5;
     TVector<TString> UdfFiles;
     TString QueryFile;