| 2090 | } |
| 2091 | |
| 2092 | std::shared_ptr<::arrow::ChunkedArray> GetResult() override { |
| 2093 | FlushBuilder(); |
| 2094 | std::vector<std::shared_ptr<::arrow::Array>> result; |
| 2095 | std::swap(result, result_chunks_); |
| 2096 | return std::make_shared<::arrow::ChunkedArray>(std::move(result), builder_.type()); |
| 2097 | } |
| 2098 | |
| 2099 | void FlushBuilder() { |
| 2100 | if (builder_.length() > 0) { |