Thrill  0.1
ReadLinesNode::InputLineIteratorCompressed Class Reference

Detailed Description

InputLineIterator gives you access to lines of a file.

Definition at line 296 of file read_lines.hpp.

+ Inheritance diagram for ReadLinesNode::InputLineIteratorCompressed:
+ Collaboration diagram for ReadLinesNode::InputLineIteratorCompressed:

Public Member Functions

 InputLineIteratorCompressed (const vfs::FileList &files, ReadLinesNode &node, bool local_storage)
 Creates an instance of iterator that reads file line based. More...
 
bool HasNext ()
 returns true, if an element is available in local part More...
 
const std::string & Next ()
 
- Public Member Functions inherited from ReadLinesNode::InputLineIterator
 InputLineIterator (const vfs::FileList &files, ReadLinesNode &node)
 
 InputLineIterator (const InputLineIterator &)=delete
 non-copyable: delete copy-constructor More...
 
 InputLineIterator (InputLineIterator &&)=default
 move-constructor: default More...
 
InputLineIteratoroperator= (const InputLineIterator &)=delete
 non-copyable: delete assignment operator More...
 
InputLineIteratoroperator= (InputLineIterator &&)=default
 move-assignment operator: default More...
 

Private Attributes

vfs::ReadStreamPtr stream_
 File handle to files_[file_nr_]. More...
 

Additional Inherited Members

- Protected Member Functions inherited from ReadLinesNode::InputLineIterator
 ~InputLineIterator ()
 
bool ReadBlock (vfs::ReadStreamPtr &file, net::BufferBuilder &buffer)
 
- Protected Attributes inherited from ReadLinesNode::InputLineIterator
net::BufferBuilder buffer_
 Byte buffer to create line std::string values. More...
 
unsigned char * current_
 Start of next element in current buffer. More...
 
std::string data_
 String, which Next() references to. More...
 
size_t file_nr_
 Index of current file in files_. More...
 
const vfs::FileListfiles_
 Input files with size prefixsum. More...
 
common::Range my_range_
 (exclusive) [begin,end) of local block More...
 
ReadLinesNodenode_
 Reference to node. More...
 
const size_t read_size = data::default_block_size
 Block read size. More...
 
common::StatsTimerStopped read_timer
 
size_t total_bytes_ = 0
 
size_t total_elements_ = 0
 
size_t total_reads_ = 0
 

Constructor & Destructor Documentation

◆ InputLineIteratorCompressed()

Member Function Documentation

◆ HasNext()

◆ Next()

Member Data Documentation

◆ stream_

vfs::ReadStreamPtr stream_
private

File handle to files_[file_nr_].

Definition at line 439 of file read_lines.hpp.


The documentation for this class was generated from the following file: