Given a set of RPageSources merge them into an RPageSink, optionally changing their compression.
This can also be used to change the compression of a single RNTuple by just passing a single source.
Definition at line 89 of file RNTupleMerger.hxx.
Public Member Functions | |
RNTupleMerger (std::unique_ptr< RPageSink > destination) | |
Creates a RNTupleMerger with the given destination. | |
RResult< void > | Merge (std::span< RPageSource * > sources, const RNTupleMergeOptions &mergeOpts=RNTupleMergeOptions()) |
Merge a given set of sources into the destination. | |
Private Member Functions | |
RNTupleMerger (std::unique_ptr< RPageSink > destination, std::unique_ptr< RNTupleModel > model) | |
Creates a RNTupleMerger with the given destination. | |
void | MergeCommonColumns (RClusterPool &clusterPool, ROOT::DescriptorId_t clusterId, std::span< RColumnMergeInfo > commonColumns, const RCluster::ColumnSet_t &commonColumnSet, RSealedPageMergeData &sealedPageData, const RNTupleMergeData &mergeData) |
void | MergeSourceClusters (RPageSource &source, std::span< RColumnMergeInfo > commonColumns, std::span< RColumnMergeInfo > extraDstColumns, RNTupleMergeData &mergeData) |
Private Attributes | |
std::unique_ptr< RPageSink > | fDestination |
std::unique_ptr< RNTupleModel > | fModel |
std::unique_ptr< RPageAllocator > | fPageAlloc |
std::optional< TTaskGroup > | fTaskGroup |
Friends | |
class | ROOT::RNTuple |
#include <ROOT/RNTupleMerger.hxx>
|
private |
Creates a RNTupleMerger with the given destination.
The model must be given if and only if destination
has been initialized with that model (i.e. in case of incremental merging).
Definition at line 916 of file RNTupleMerger.cxx.
|
explicit |
Creates a RNTupleMerger with the given destination.
Definition at line 929 of file RNTupleMerger.cxx.
ROOT::RResult< void > RNTupleMerger::Merge | ( | std::span< RPageSource * > | sources, |
const RNTupleMergeOptions & | mergeOpts = RNTupleMergeOptions() ) |
Merge a given set of sources into the destination.
Definition at line 931 of file RNTupleMerger.cxx.
|
private |
Definition at line 580 of file RNTupleMerger.cxx.
|
private |
Definition at line 750 of file RNTupleMerger.cxx.
|
friend |
Definition at line 90 of file RNTupleMerger.hxx.
|
private |
Definition at line 92 of file RNTupleMerger.hxx.
|
private |
Definition at line 95 of file RNTupleMerger.hxx.
|
private |
Definition at line 93 of file RNTupleMerger.hxx.
|
private |
Definition at line 94 of file RNTupleMerger.hxx.