A RDataFrame node that produces a result.
Helper | The action helper type, which implements the concrete action logic (e.g. FillHelper, SnapshotHelper) |
PrevNode | The type of the parent node in the computation graph |
ColumnTypes_t | A TypeList with the types of the input columns |
Definition at line 53 of file RAction.hxx.
Public Member Functions | |
RAction (const RAction &)=delete | |
RAction (Helper &&h, const ColumnNames_t &columns, std::shared_ptr< PrevNode > pd, const RColumnRegister &colRegister) | |
~RAction () | |
template<typename... ColTypes, std::size_t... S> | |
void | CallExec (unsigned int slot, Long64_t entry, TypeList< ColTypes... >, std::index_sequence< S... >) |
std::unique_ptr< RActionBase > | CloneAction (void *newResult) final |
Returns a new action with a cloned helper. | |
void | Finalize () final |
Clean-up and finalize the action result (e.g. | |
void | FinalizeSlot (unsigned int slot) final |
Clean-up operations to be performed at the end of a task. | |
std::shared_ptr< RDFGraphDrawing::GraphNode > | GetGraph (std::unordered_map< void *, std::shared_ptr< RDFGraphDrawing::GraphNode > > &visitedMap) final |
std::unique_ptr< RDFDetail::RMergeableValueBase > | GetMergeableValue () const final |
Retrieve a wrapper to the result of the action that knows how to merge with others of the same type. | |
template<typename ColType > | |
auto | GetValueChecked (unsigned int slot, std::size_t readerIdx, Long64_t entry) -> ColType & |
void | Initialize () final |
void | InitSlot (TTreeReader *r, unsigned int slot) final |
std::unique_ptr< RActionBase > | MakeVariedAction (std::vector< void * > &&results) final |
RAction & | operator= (const RAction &)=delete |
void * | PartialUpdate (unsigned int slot) final |
This method is invoked to update a partial result during the event loop, right before passing the result to a user-defined callback registered via RResultPtr::RegisterCallback. | |
void | Run (unsigned int slot, Long64_t entry) final |
void | TriggerChildrenCount () final |
Public Member Functions inherited from ROOT::Internal::RDF::RActionBase | |
RActionBase (const RActionBase &)=delete | |
RActionBase (RLoopManager *lm, const ColumnNames_t &colNames, const RColumnRegister &colRegister, const std::vector< std::string > &prevVariations) | |
virtual | ~RActionBase () |
RColumnRegister & | GetColRegister () |
const ColumnNames_t & | GetColumnNames () const |
RLoopManager * | GetLoopManager () |
unsigned int | GetNSlots () const |
const std::vector< std::string > & | GetVariations () const |
virtual bool | HasRun () const |
RActionBase & | operator= (const RActionBase &)=delete |
virtual void | SetHasRun () |
Private Types | |
using | TypeInd_t = std::make_index_sequence< ColumnTypes_t::list_size > |
Private Member Functions | |
ROOT::RDF::SampleCallback_t | GetSampleCallback () final |
Private Attributes | |
Helper | fHelper |
std::array< bool, ColumnTypes_t::list_size > | fIsDefine |
The nth flag signals whether the nth input column is a custom column or not. | |
PrevNode & | fPrevNode |
const std::shared_ptr< PrevNode > | fPrevNodePtr |
std::vector< std::array< RColumnReaderBase *, ColumnTypes_t::list_size > > | fValues |
Column readers per slot and per input column. | |
Additional Inherited Members | |
Protected Attributes inherited from ROOT::Internal::RDF::RActionBase | |
const ColumnNames_t | fColumnNames |
RLoopManager * | fLoopManager |
A raw pointer to the RLoopManager at the root of this functional graph. | |
#include <ROOT/RDF/RAction.hxx>
|
private |
Definition at line 54 of file RAction.hxx.
|
inline |
Definition at line 66 of file RAction.hxx.
|
delete |
|
inline |
Definition at line 80 of file RAction.hxx.
|
inline |
Definition at line 115 of file RAction.hxx.
|
inlinefinalvirtual |
Returns a new action with a cloned helper.
[in] | newResult | The result to be filled by the new action (needed to clone the helper). |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 190 of file RAction.hxx.
|
inlinefinalvirtual |
Clean-up and finalize the action result (e.g.
merging slot-local results). It invokes the helper's Finalize method.
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 140 of file RAction.hxx.
|
inlinefinalvirtual |
Clean-up operations to be performed at the end of a task.
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 132 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 147 of file RAction.hxx.
|
inlinefinalvirtual |
Retrieve a wrapper to the result of the action that knows how to merge with others of the same type.
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 86 of file RAction.hxx.
|
inlinefinalprivatevirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 197 of file RAction.hxx.
|
inline |
Definition at line 102 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 91 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 93 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 169 of file RAction.hxx.
|
delete |
|
inlinefinalvirtual |
This method is invoked to update a partial result during the event loop, right before passing the result to a user-defined callback registered via RResultPtr::RegisterCallback.
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 167 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 122 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 129 of file RAction.hxx.
|
private |
Definition at line 56 of file RAction.hxx.
|
private |
The nth flag signals whether the nth input column is a custom column or not.
Definition at line 63 of file RAction.hxx.
|
private |
Definition at line 58 of file RAction.hxx.
|
private |
Definition at line 57 of file RAction.hxx.
|
private |
Column readers per slot and per input column.
Definition at line 60 of file RAction.hxx.