MCPcopy Create free account
hub / github.com/bytedance/bolt / read

Method read

bolt/dwio/common/CachedBufferedInput.cpp:544–561  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

542 LogType /*logType*/) const {
543 BOLT_CHECK_LE(offset + length, fileSize_);
544 return std::make_unique<CacheInputStream>(
545 const_cast<CachedBufferedInput*>(this),
546 ioStats_.get(),
547 Region{offset, length},
548 input_,
549 fileNum_,
550 cacheable_,
551 columnCacheBlackList_,
552 nullptr,
553 TrackingId(),
554 0,
555 options_.loadQuantum());
556}
557
558bool CachedBufferedInput::prefetch(Region region) {
559 int32_t numPages = memory::AllocationTraits::numPages(region.length);
560 if (!shouldPreload(numPages)) {
561 return false;
562 }
563 auto stream = enqueue(region, nullptr);
564 load(LogType::FILE);

Callers 2

updateStatsMethod · 0.45
loadDataMethod · 0.45

Calls 3

TrackingIdClass · 0.85
getMethod · 0.45
loadQuantumMethod · 0.45

Tested by

no test coverage detected