Skip to content

Commit 4d29f0f

Browse files
authored
Add canonical result for tpcds s10 and s100 (#12001)
1 parent decc7f1 commit 4d29f0f

File tree

202 files changed

+10
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

202 files changed

+10
-0
lines changed

ydb/library/workload/tpc_base/tpc_base.cpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
#include <ydb/public/lib/scheme_types/scheme_type_id.h>
55

66
#include <library/cpp/resource/resource.h>
7+
#include <library/cpp/streams/factory/open_by_signature/factory.h>
78
#include <util/stream/file.h>
89
#include <util/string/split.h>
910
#include <util/string/strip.h>
@@ -78,6 +79,10 @@ TQueryInfoList TTpcBaseWorkloadGenerator::GetWorkload(int type) {
7879
const auto key = resourcePrefix + "s" + ToString(Params.GetScale()) + "_canonical/q" + ToString(&query - queries.data()) + ".result";
7980
if (NResource::Has(key)) {
8081
result.back().ExpectedResult = NResource::Find(key);
82+
} else if (NResource::Has(key + ".gz")) {
83+
const auto data = NResource::Find(key + ".gz");
84+
auto input = OpenOwnedMaybeCompressedInput(MakeHolder<TStringInput>(data));
85+
result.back().ExpectedResult = input->ReadAll();
8186
}
8287
}
8388
}

ydb/library/workload/tpc_base/ya.make

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ RESOURCE(
1111

1212
PEERDIR(
1313
library/cpp/resource
14+
library/cpp/streams/factory/open_by_signature
1415
ydb/library/accessor
1516
ydb/library/workload/benchmark_base
1617
ydb/public/lib/scheme_types
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.

0 commit comments

Comments
 (0)