![]() |
Project
|
#include "Framework/DataRefUtils.h"
#include "Framework/AlgorithmSpec.h"
#include "Framework/DataAllocator.h"
#include "Framework/ServiceRegistry.h"
#include "Framework/runDataProcessing.h"
#include "Framework/ControlService.h"
#include "Framework/Logger.h"
#include "Framework/TableBuilder.h"
#include "Framework/TableConsumer.h"
#include <Monitoring/Monitoring.h>
#include <ROOT/RDataFrame.hxx>
#include <ROOT/RArrowDS.hxx>
#include <memory>
Go to the source code of this file.
Functions | |
WorkflowSpec | defineDataProcessing (ConfigContext const &) |
Example of how to use ROOT::RDataFrame using DPL. | |
WorkflowSpec defineDataProcessing | ( | ConfigContext const & | configcontext | ) |
Example of how to use ROOT::RDataFrame using DPL.
This function hooks up the the workflow specifications into the DPL driver.
This gets a table handle from the message.
From the handle, we construct the actual arrow table which is then used as a source for the RDataFrame. This is probably easy to change to a:
auto rdf = ctx.inputs().get<RDataSource>("xz");
Definition at line 29 of file test_SimpleRDataFrameProcessing.cxx.