| 315 | } |
| 316 | |
| 317 | TableReaderFactory MakeStreamingFactory(bool use_threads = true) { |
| 318 | return [use_threads]( |
| 319 | std::shared_ptr<io::InputStream> input_stream, ParseOptions parse_options, |
| 320 | std::optional<int32_t> block_size) -> Result<std::shared_ptr<TableReader>> { |
| 321 | auto read_options = ReadOptions::Defaults(); |
| 322 | read_options.block_size = block_size.value_or(1 << 10); |
| 323 | read_options.use_threads = use_threads; |
| 324 | ARROW_ASSIGN_OR_RAISE( |
| 325 | auto streaming_reader, |
| 326 | StreamingReader::Make(io::default_io_context(), input_stream, read_options, |
| 327 | std::move(parse_options), ConvertOptions::Defaults())); |
| 328 | return std::make_shared<StreamingReaderAsTableReader>(std::move(streaming_reader)); |
| 329 | }; |
| 330 | } |
| 331 | |
| 332 | Result<StreamingReaderFactory> MakeStreamingReaderFactory() { |
| 333 | return [](std::shared_ptr<io::InputStream> input_stream) |