Page source information consumed while running the computation graph.
REntryRangeDS objects are populated differently in single-thread and multi-thread mode.
In single-thread mode, the PrepareNextRanges() method populates the fNextRanges list with REntryRangeDS records. The GetEntryRanges() swaps fNextRanges and fCurrentRanges and uses the list of REntryRangeDS records to return the list of ranges ready to use by the RDF loop manager.
In multi-thread mode, the task being executed by a thread injects an REntryRangeDS into the fActiveRangesPerSlot member, which is then retrievable for relevant operations e.g. connecting the column readers to the page source and populating the sample information.
Definition at line 114 of file RNTupleDS.hxx.
Public Attributes | |
| ULong64_t | fEntryOffset = 0 |
| std::string_view | fFileName |
| Offset of both first and last entries w.r.t. the page source. | |
| ULong64_t | fFirstEntry = 0 |
| First entry index in fSource. | |
| ULong64_t | fLastEntry = 0 |
| End entry index in fSource, e.g. the number of entries in the range is fLastEntry - fFirstEntry. | |
| std::shared_ptr< ROOT::Internal::RPageSource > | fSource |
| The page source. It can be shared between this object and other multithreaded tasks. | |
| ULong64_t ROOT::RDF::RNTupleDS::REntryRangeDS::fEntryOffset = 0 |
Definition at line 126 of file RNTupleDS.hxx.
| std::string_view ROOT::RDF::RNTupleDS::REntryRangeDS::fFileName |
Offset of both first and last entries w.r.t. the page source.
Storage location of the current RNTuple
Definition at line 127 of file RNTupleDS.hxx.
| ULong64_t ROOT::RDF::RNTupleDS::REntryRangeDS::fFirstEntry = 0 |
First entry index in fSource.
Definition at line 117 of file RNTupleDS.hxx.
| ULong64_t ROOT::RDF::RNTupleDS::REntryRangeDS::fLastEntry = 0 |
End entry index in fSource, e.g. the number of entries in the range is fLastEntry - fFirstEntry.
Definition at line 119 of file RNTupleDS.hxx.
| std::shared_ptr<ROOT::Internal::RPageSource> ROOT::RDF::RNTupleDS::REntryRangeDS::fSource |
The page source. It can be shared between this object and other multithreaded tasks.
Definition at line 116 of file RNTupleDS.hxx.