Skip to content

Commit

Permalink
Refactor: Fix style
Browse files Browse the repository at this point in the history
Signed-off-by: Ziy1-Tan <[email protected]>
  • Loading branch information
Ziy1-Tan committed Jul 4, 2023
1 parent 519e1ef commit 5b43a7c
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion cpp/src/filesystem.cc
Original file line number Diff line number Diff line change
Expand Up @@ -103,7 +103,7 @@ Result<std::shared_ptr<arrow::Table>> FileSystem::ReadFileToTable(
GAR_RETURN_ON_ARROW_ERROR_AND_ASSIGN(auto dataset, factory->Finish());
GAR_RETURN_ON_ARROW_ERROR_AND_ASSIGN(auto scan_builder, dataset->NewScan());

// Read specified columns with a row filter
// Apply the row filter and select the specified columns
if (options.filter) {
RETURN_NOT_ARROW_OK(scan_builder->Filter(options.filter->Evaluate()));
}
Expand Down
4 changes: 2 additions & 2 deletions cpp/test/test_arrow_chunk_reader.cc
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ TEST_CASE("test_vertex_property_pushdown") {
<< chunk_size << ",\tRange: [" << l << ", " << r << "]" << '\n';
i++;
sum += table->num_rows();
} while (!reader.next_chunk().IsOutOfRange());
} while (!reader.next_chunk().IsIndexError());

std::cout << "Total Nums: " << sum << "/"
<< reader.GetChunkNum() * chunk_size << '\n';
Expand Down Expand Up @@ -326,7 +326,7 @@ TEST_CASE("test_adj_list_property_pushdown") {
<< chunk_size << '\n';
i++;
sum += table->num_rows();
} while (!reader.next_chunk().IsOutOfRange());
} while (!reader.next_chunk().IsIndexError());

std::cout << "Total Nums: " << sum << "/" << i * chunk_size << '\n';
std::cout << "Column Nums: " << names.size() << "\n";
Expand Down

0 comments on commit 5b43a7c

Please sign in to comment.