A RDataFrame node that produces a result.
Helper | The action helper type, which implements the concrete action logic (e.g. FillHelper, SnapshotHelper) |
PrevDataFrame | The type of the parent node in the computation graph |
ColumnTypes_t | A TypeList with the types of the input columns |
Definition at line 52 of file RAction.hxx.
Public Member Functions | |
RAction (const RAction &)=delete | |
RAction (Helper &&h, const ColumnNames_t &columns, std::shared_ptr< PrevDataFrame > pd, const RBookedDefines &defines) | |
~RAction () | |
template<typename... ColTypes, std::size_t... S> | |
void | CallExec (unsigned int slot, Long64_t entry, TypeList< ColTypes... >, std::index_sequence< S... >) |
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::function< void(unsigned int)> | GetDataBlockCallback () final |
std::shared_ptr< RDFGraphDrawing::GraphNode > | GetGraph () |
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. | |
void | Initialize () final |
void | InitSlot (TTreeReader *r, unsigned int slot) 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 RBookedDefines &defines) | |
virtual | ~RActionBase () |
const ColumnNames_t & | GetColumnNames () const |
RBookedDefines & | GetDefines () |
RLoopManager * | GetLoopManager () |
unsigned int | GetNSlots () 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 | |
void * | PartialUpdateImpl (...) |
template<typename H = Helper> | |
auto | PartialUpdateImpl (unsigned int slot) -> decltype(std::declval< H >().PartialUpdate(slot),(void *)(nullptr)) |
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. | |
PrevDataFrame & | fPrevData |
const std::shared_ptr< PrevDataFrame > | fPrevDataPtr |
std::vector< std::array< std::unique_ptr< 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 | |
RLoopManager * | fLoopManager |
A raw pointer to the RLoopManager at the root of this functional graph. | |
#include <ROOT/RDF/RAction.hxx>
|
private |
Definition at line 53 of file RAction.hxx.
|
inline |
Definition at line 65 of file RAction.hxx.
|
delete |
|
inline |
Definition at line 79 of file RAction.hxx.
|
inline |
Definition at line 103 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 130 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 119 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 156 of file RAction.hxx.
|
inlinevirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 136 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 85 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 90 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 92 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 154 of file RAction.hxx.
|
inlineprivate |
Definition at line 168 of file RAction.hxx.
|
inlineprivate |
Definition at line 162 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 109 of file RAction.hxx.
|
inlinefinalvirtual |
Implements ROOT::Internal::RDF::RActionBase.
Definition at line 116 of file RAction.hxx.
|
private |
Definition at line 55 of file RAction.hxx.
|
private |
The nth flag signals whether the nth input column is a custom column or not.
Definition at line 62 of file RAction.hxx.
|
private |
Definition at line 57 of file RAction.hxx.
|
private |
Definition at line 56 of file RAction.hxx.
|
private |
Column readers per slot and per input column.
Definition at line 59 of file RAction.hxx.