MCPcopy Create free account
hub / github.com/apache/arrow / for

Function for

cpp/src/parquet/arrow/reader.cc:826–833  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

824 }
825
826 END_PARQUET_CATCH_EXCEPTIONS
827 // Gather children arrays and def levels
828 for (auto& child : children_) {
829 std::shared_ptr<ChunkedArray> field;
830 RETURN_NOT_OK(child->BuildArray(validity_io.values_read, &field));
831 ARROW_ASSIGN_OR_RAISE(std::shared_ptr<ArrayData> array_data, ChunksToSingle(*field));
832 children_array_data.push_back(std::move(array_data));
833 }
834
835 if (!filtered_field_->nullable() && !has_repeated_child_) {
836 validity_io.values_read = children_array_data.front()->length;

Callers 6

ASSERT_OK_AND_ASSIGNFunction · 0.85
ARROW_ASSIGN_OR_RAISEMethod · 0.85
TestFromUriAbfsMethod · 0.85
aligned_storage.hFile · 0.85
ASSERT_OK_AND_ASSIGNFunction · 0.85
MakeGroupableBatchesFunction · 0.85

Calls 4

ChunksToSingleFunction · 0.85
push_backMethod · 0.80
ARROW_ASSIGN_OR_RAISEFunction · 0.70
BuildArrayMethod · 0.45

Tested by 4

ASSERT_OK_AND_ASSIGNFunction · 0.68
ARROW_ASSIGN_OR_RAISEMethod · 0.68
TestFromUriAbfsMethod · 0.68
ASSERT_OK_AND_ASSIGNFunction · 0.68