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

Method OpenAsync

cpp/src/arrow/ipc/reader.cc:1506–1512  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1504 }
1505
1506 Future<> OpenAsync(const std::shared_ptr<io::RandomAccessFile>& file,
1507 int64_t footer_offset, const IpcReadOptions& options) {
1508 owned_file_ = file;
1509 metadata_cache_ = std::make_shared<io::internal::ReadRangeCache>(
1510 file, file->io_context(), options.pre_buffer_cache_options);
1511 return OpenAsync(file.get(), footer_offset, options);
1512 }
1513
1514 Future<> OpenAsync(io::RandomAccessFile* file, int64_t footer_offset,
1515 const IpcReadOptions& options) {

Callers

nothing calls this directly

Calls 6

GetCpuThreadPoolFunction · 0.85
UnpackSchemaMessageFunction · 0.85
ThenMethod · 0.80
OKFunction · 0.50
getMethod · 0.45
schemaMethod · 0.45

Tested by

no test coverage detected