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

Method Init

cpp/src/arrow/json/reader.cc:248–253  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

246 task_group_(std::move(task_group)) {}
247
248 Status Init(std::shared_ptr<io::InputStream> input) {
249 ARROW_ASSIGN_OR_RAISE(auto it,
250 io::MakeInputStreamIterator(input, read_options_.block_size));
251 return MakeReadaheadIterator(std::move(it), task_group_->parallelism())
252 .Value(&buffer_iterator_);
253 }
254
255 Result<std::shared_ptr<Table>> Read() override {
256 auto block_it = MakeChunkingIterator(std::move(buffer_iterator_),

Callers 1

MakeMethod · 0.45

Calls 3

MakeReadaheadIteratorFunction · 0.85
ValueMethod · 0.45
parallelismMethod · 0.45

Tested by

no test coverage detected