Detailed Description
template<typename ValueType>
class thrill::api::ReadBinaryNode< ValueType >::VfsFileBlockSource
Definition at line 273 of file read_binary.hpp.
Collaboration diagram for ReadBinaryNode< ValueType >::VfsFileBlockSource:Public Member Functions | |
| VfsFileBlockSource (const FileInfo &fileinfo, Context &ctx, size_t &stats_total_bytes, size_t &stats_total_reads) | |
| data::PinnedBlock | NextBlock () |
Public Attributes | |
| const size_t | block_size = data::default_block_size |
Private Attributes | |
| Context & | context_ |
| bool | done_ = false |
| bool | is_compressed_ |
| size_t | remain_size_ |
| size_t & | stats_total_bytes_ |
| size_t & | stats_total_reads_ |
| vfs::ReadStreamPtr | stream_ |
Constructor & Destructor Documentation
◆ VfsFileBlockSource()
|
inline |
Definition at line 278 of file read_binary.hpp.
References thrill::vfs::OpenReadStream(), ReadBinaryNode< ValueType >::FileInfo::path, and ReadBinaryNode< ValueType >::FileInfo::range.
Member Function Documentation
◆ NextBlock()
|
inline |
Definition at line 296 of file read_binary.hpp.
References BlockPool::AllocateByteBlock(), Context::block_pool(), bytes, DIABase::context_, Context::local_worker_id(), LOG, and min().
Member Data Documentation
◆ block_size
| const size_t block_size = data::default_block_size |
Definition at line 276 of file read_binary.hpp.
◆ context_
|
private |
Definition at line 333 of file read_binary.hpp.
◆ done_
|
private |
Definition at line 339 of file read_binary.hpp.
◆ is_compressed_
|
private |
Definition at line 336 of file read_binary.hpp.
◆ remain_size_
|
private |
Definition at line 335 of file read_binary.hpp.
◆ stats_total_bytes_
|
private |
Definition at line 337 of file read_binary.hpp.
◆ stats_total_reads_
|
private |
Definition at line 338 of file read_binary.hpp.
◆ stream_
|
private |
Definition at line 334 of file read_binary.hpp.
The documentation for this class was generated from the following file:
- thrill/api/read_binary.hpp
