Skip to content

Commit

Permalink
fix test build
Browse files Browse the repository at this point in the history
  • Loading branch information
ivanmorozov333 committed Jan 15, 2024
1 parent 99dab05 commit 16daa4a
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions ydb/core/tx/columnshard/engines/ut_logs_engine.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -69,14 +69,14 @@ class TTestDbWrapper : public IDbWrapper {
return true;
}

void WriteColumn(ui32 index, const TPortionInfo& portion, const TColumnRecord& row) override {
void WriteColumn(const TPortionInfo& portion, const TColumnRecord& row) override {
auto proto = portion.GetMeta().SerializeToProto(row.ColumnId, row.Chunk);
auto rowProto = row.GetMeta().SerializeToProto();
if (proto) {
*rowProto.MutablePortionMeta() = std::move(*proto);
}

auto& data = Indices[index].Columns[portion.GetPathId()];
auto& data = Indices[0].Columns[portion.GetPathId()];
NOlap::TColumnChunkLoadContext loadContext(row.GetAddress(), row.BlobRange, rowProto);
auto itInsertInfo = LoadContexts[portion.GetAddress()].emplace(row.GetAddress(), loadContext);
if (!itInsertInfo.second) {
Expand Down Expand Up @@ -104,8 +104,8 @@ class TTestDbWrapper : public IDbWrapper {
}
}

void EraseColumn(ui32 index, const TPortionInfo& portion, const TColumnRecord& row) override {
auto& data = Indices[index].Columns[portion.GetPathId()];
void EraseColumn(const TPortionInfo& portion, const TColumnRecord& row) override {
auto& data = Indices[0].Columns[portion.GetPathId()];
auto it = data.find(portion.GetPortion());
Y_ABORT_UNLESS(it != data.end());
auto& portionLocal = it->second;
Expand All @@ -119,8 +119,8 @@ class TTestDbWrapper : public IDbWrapper {
portionLocal.Records.swap(filtered);
}

bool LoadColumns(ui32 index, const std::function<void(const TPortionInfo&, const TColumnChunkLoadContext&)>& callback) override {
auto& columns = Indices[index].Columns;
bool LoadColumns(const std::function<void(const TPortionInfo&, const TColumnChunkLoadContext&)>& callback) override {
auto& columns = Indices[0].Columns;
for (auto& [pathId, portions] : columns) {
for (auto& [portionId, portionLocal] : portions) {
auto copy = portionLocal;
Expand All @@ -137,13 +137,13 @@ class TTestDbWrapper : public IDbWrapper {
return true;
}

void WriteCounter(ui32 index, ui32 counterId, ui64 value) override {
auto& counters = Indices[index].Counters;
void WriteCounter(ui32 counterId, ui64 value) override {
auto& counters = Indices[0].Counters;
counters[counterId] = value;
}

bool LoadCounters(ui32 index, const std::function<void(ui32 id, ui64 value)>& callback) override {
auto& counters = Indices[index].Counters;
bool LoadCounters(const std::function<void(ui32 id, ui64 value)>& callback) override {
auto& counters = Indices[0].Counters;
for (auto& [id, value] : counters) {
callback(id, value);
}
Expand Down

0 comments on commit 16daa4a

Please sign in to comment.