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

Method InitializeStream

cpp/src/arrow/filesystem/gcsfs.cc:321–327  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

319
320 private:
321 Status InitializeStream() const {
322 if (!stream_) {
323 ARROW_ASSIGN_OR_RAISE(stream_, factory_(gcs::Generation(metadata_.generation()),
324 gcs::ReadRange(), gcs::ReadFromOffset()));
325 }
326 return Status::OK();
327 }
328 InputStreamFactory factory_;
329 gcs::ObjectMetadata metadata_;
330 std::shared_ptr<GcsInputStream> mutable stream_;

Callers

nothing calls this directly

Calls 3

ARROW_ASSIGN_OR_RAISEFunction · 0.50
ReadRangeClass · 0.50
OKFunction · 0.50

Tested by

no test coverage detected