| 2105 | } |
| 2106 | |
| 2107 | std::shared_ptr<::arrow::ChunkedArray> GetResult() override { |
| 2108 | FlushBuilder(); |
| 2109 | std::vector<std::shared_ptr<::arrow::Array>> result; |
| 2110 | std::swap(result, result_chunks_); |
| 2111 | return std::make_shared<::arrow::ChunkedArray>(std::move(result), builder_.type()); |
| 2112 | } |
| 2113 | |
| 2114 | void FlushBuilder() { |
| 2115 | if (builder_.length() > 0) { |