| 2437 | std::shared_ptr<DataType> data_type() const { return field_->type(); } |
| 2438 | |
| 2439 | Status ReadNext(std::shared_ptr<Array>* array) { |
| 2440 | ARROW_RETURN_NOT_OK(this->CheckNotReleased()); |
| 2441 | |
| 2442 | ArrayType c_array; |
| 2443 | ARROW_RETURN_NOT_OK(this->ReadNextArrayInternal(&c_array)); |
| 2444 | |
| 2445 | if (ArrayTraits::IsReleasedFunc(&c_array)) { |
| 2446 | // End of stream |
| 2447 | array->reset(); |
| 2448 | return Status::OK(); |
| 2449 | } else { |
| 2450 | return this->ImportArrayInternal(&c_array, field_->type()).Value(array); |
| 2451 | } |
| 2452 | } |
| 2453 | |
| 2454 | private: |
| 2455 | std::shared_ptr<Field> field_; |
nothing calls this directly
no test coverage detected