|
| RNTupleProcessor (const RNTupleProcessor &)=delete |
|
| RNTupleProcessor (RNTupleProcessor &&)=delete |
|
virtual | ~RNTupleProcessor ()=default |
|
RIterator | begin () |
|
RIterator | end () |
|
ROOT::NTupleSize_t | GetCurrentEntryNumber () const |
| Get the entry number that is currently being processed.
|
|
std::size_t | GetCurrentProcessorNumber () const |
| Get the number of the inner processor currently being read.
|
|
const REntry & | GetEntry () const |
| Returns a reference to the entry used by the processor.
|
|
const RNTupleModel & | GetModel () const |
|
ROOT::NTupleSize_t | GetNEntriesProcessed () const |
| Get the total number of entries processed so far.
|
|
const std::string & | GetProcessorName () const |
| Get the name of the processor.
|
|
RNTupleProcessor & | operator= (const RNTupleProcessor &)=delete |
|
RNTupleProcessor & | operator= (RNTupleProcessor &&)=delete |
|
static std::unique_ptr< RNTupleProcessor > | Create (const RNTupleOpenSpec &ntuple, std::string_view processorName, std::unique_ptr< RNTupleModel > model=nullptr) |
| Create an RNTupleProcessor for a single RNTuple.
|
|
static std::unique_ptr< RNTupleProcessor > | Create (const RNTupleOpenSpec &ntuple, std::unique_ptr< RNTupleModel > model=nullptr) |
| Create an RNTupleProcessor for a single RNTuple.
|
|
static std::unique_ptr< RNTupleProcessor > | CreateChain (const std::vector< RNTupleOpenSpec > &ntuples, std::string_view processorName, std::unique_ptr< RNTupleModel > model=nullptr) |
| Create a new RNTuple processor chain for vertical combinations of RNTuples.
|
|
static std::unique_ptr< RNTupleProcessor > | CreateChain (const std::vector< RNTupleOpenSpec > &ntuples, std::unique_ptr< RNTupleModel > model=nullptr) |
| Create a new RNTuple processor chain for vertical concatenation of RNTuples.
|
|
static std::unique_ptr< RNTupleProcessor > | CreateChain (std::vector< std::unique_ptr< RNTupleProcessor > > innerProcessors, std::string_view processorName, std::unique_ptr< RNTupleModel > model=nullptr) |
| Create a new RNTuple processor chain for vertically combining other RNTupleProcessors.
|
|
static std::unique_ptr< RNTupleProcessor > | CreateChain (std::vector< std::unique_ptr< RNTupleProcessor > > innerProcessors, std::unique_ptr< RNTupleModel > model=nullptr) |
| Create a new RNTuple processor chain for vertical concatenation of previously created processors.
|
|
static std::unique_ptr< RNTupleProcessor > | CreateJoin (const std::vector< RNTupleOpenSpec > &ntuples, const std::vector< std::string > &joinFields, std::string_view processorName, std::vector< std::unique_ptr< RNTupleModel > > models={}) |
| Create a new RNTuple processor for horizontally combined RNTuples.
|
|
static std::unique_ptr< RNTupleProcessor > | CreateJoin (const std::vector< RNTupleOpenSpec > &ntuples, const std::vector< std::string > &joinFields, std::vector< std::unique_ptr< RNTupleModel > > models={}) |
| Create a new RNTuple processor for horizontallly concatenated RNTuples.
|
|
| RNTupleProcessor (std::string_view processorName, std::unique_ptr< RNTupleModel > model) |
| Create a new base RNTupleProcessor.
|
|
void | ConnectField (RFieldContext &fieldContext, Internal::RPageSource &pageSource, REntry &entry) |
| Creates and connects a concrete field to the current page source, based on its proto field.
|
|
ROOT::NTupleSize_t | fCurrentEntryNumber = 0 |
|
std::size_t | fCurrentProcessorNumber = 0 |
|
std::unique_ptr< REntry > | fEntry |
|
std::unordered_map< std::string, RFieldContext > | fFieldContexts |
|
std::unique_ptr< RNTupleModel > | fModel |
|
ROOT::NTupleSize_t | fNEntries = kInvalidNTupleIndex |
| Total number of entries.
|
|
ROOT::NTupleSize_t | fNEntriesProcessed = 0 |
|
std::vector< RNTupleOpenSpec > | fNTuples |
|
std::unique_ptr< Internal::RPageSource > | fPageSource |
|
std::string | fProcessorName |
|