@@ -23,10 +23,10 @@ namespace NKikimr {
23
23
namespace NMiniKQL {
24
24
25
25
template <typename K>
26
- void UpdateMapFromBlocks (const NUdf::TUnboxedValue& key, const NUdf::TUnboxedValue& value, std::unordered_map<K, uint64_t >& result);
26
+ void UpdateMapFromBlocks (const NUdf::TUnboxedValue& key, const NUdf::TUnboxedValue& value, std::unordered_map<K, ui64 >& result);
27
27
28
28
template <>
29
- void UpdateMapFromBlocks (const NUdf::TUnboxedValue& key, const NUdf::TUnboxedValue& value, std::unordered_map<uint64_t , uint64_t >& result)
29
+ void UpdateMapFromBlocks (const NUdf::TUnboxedValue& key, const NUdf::TUnboxedValue& value, std::unordered_map<ui64, ui64 >& result)
30
30
{
31
31
auto datumKey = TArrowBlock::From (key).GetDatum ();
32
32
auto datumValue = TArrowBlock::From (value).GetDatum ();
@@ -46,7 +46,7 @@ void UpdateMapFromBlocks(const NUdf::TUnboxedValue& key, const NUdf::TUnboxedVal
46
46
}
47
47
48
48
template <>
49
- void UpdateMapFromBlocks (const NUdf::TUnboxedValue& key, const NUdf::TUnboxedValue& value, std::unordered_map<std::string, uint64_t >& result)
49
+ void UpdateMapFromBlocks (const NUdf::TUnboxedValue& key, const NUdf::TUnboxedValue& value, std::unordered_map<std::string, ui64 >& result)
50
50
{
51
51
auto datumKey = TArrowBlock::From (key).GetDatum ();
52
52
auto datumValue = TArrowBlock::From (value).GetDatum ();
@@ -125,7 +125,7 @@ void RunTestBlockCombineHashedSimple(const TRunParams& params, TTestResultCollec
125
125
const auto graph = setup.BuildGraph (pgmReturn, {streamCallable});
126
126
127
127
auto streamMaker = [&]() -> auto {
128
- return std::unique_ptr<TBlockKVStream<std::string, uint64_t >>(new TBlockKVStream<std::string, uint64_t >(
128
+ return std::unique_ptr<TBlockKVStream<std::string, ui64 >>(new TBlockKVStream<std::string, ui64 >(
129
129
graph->GetContext (),
130
130
samples,
131
131
params.NumRuns ,
@@ -135,7 +135,7 @@ void RunTestBlockCombineHashedSimple(const TRunParams& params, TTestResultCollec
135
135
};
136
136
137
137
// Compute results directly from raw samples to test the input stream implementation
138
- std::unordered_map<std::string, uint64_t > rawResult;
138
+ std::unordered_map<std::string, ui64 > rawResult;
139
139
for (const auto & tuple : samples) {
140
140
rawResult[tuple.first ] += (tuple.second * params.NumRuns );
141
141
}
@@ -151,7 +151,7 @@ void RunTestBlockCombineHashedSimple(const TRunParams& params, TTestResultCollec
151
151
const auto devnullTime = TInstant::Now () - devnullStart;
152
152
153
153
// Reference implementation (sum via an std::unordered_map)
154
- std::unordered_map<std::string, uint64_t > refResult;
154
+ std::unordered_map<std::string, ui64 > refResult;
155
155
const auto refStream = streamMaker ();
156
156
const auto cppStart = TInstant::Now ();
157
157
CalcRefResult (refStream, refResult);
@@ -176,7 +176,7 @@ void RunTestBlockCombineHashedSimple(const TRunParams& params, TTestResultCollec
176
176
Cerr << " Result block count: " << numResultItems << Endl;
177
177
178
178
// Verification
179
- std::unordered_map<std::string, uint64_t > graphResult;
179
+ std::unordered_map<std::string, ui64 > graphResult;
180
180
181
181
const auto ptr = resultList.GetElements ();
182
182
for (size_t i = 0ULL ; i < numResultItems; ++i) {
@@ -206,4 +206,4 @@ template void RunTestBlockCombineHashedSimple<true, true>(const TRunParams& para
206
206
207
207
208
208
}
209
- }
209
+ }
0 commit comments