Dummy sink that discards all pages.

The RPageNullSink class is for internal testing only and can be used to measure the software overhead of serializing elements into pages, without actually writing them onto disk or even serializing the RNTuple headers and footers.

Definition at line 36 of file RPageNullSink.hxx.

Public Member Functions
	RPageNullSink (std::string_view ntupleName, const RNTupleWriteOptions &options)

ColumnHandle_t	AddColumn (DescriptorId_t, const RColumn &column) final
	Register a new column.

std::uint64_t	CommitCluster (NTupleSize_t) final
	Finalize the current cluster and create a new one for the following data.

void	CommitClusterGroup () final
	Write out the page locations (page list envelope) for all the committed clusters since the last call of CommitClusterGroup (or the beginning of writing).

void	CommitDatasetImpl () final

void	CommitPage (ColumnHandle_t, const RPage &page) final
	Write a page to the storage. The column must have been added before.

void	CommitSealedPage (DescriptorId_t, const RSealedPage &page) final
	Write a preprocessed page to storage. The column must have been added before.

void	CommitSealedPageV (std::span< RSealedPageGroup > ranges) final
	Write a vector of preprocessed pages to storage. The corresponding columns must have been added before.

void	ConnectFields (const std::vector< RFieldBase * > &fields, NTupleSize_t firstEntry)

const RNTupleDescriptor &	GetDescriptor () const final
	Return the RNTupleDescriptor being constructed.

void	InitImpl (RNTupleModel &model) final

void	ReleasePage (RPage &page) final
	Every page store needs to be able to free pages it handed out.

RPage	ReservePage (ColumnHandle_t columnHandle, std::size_t nElements) final
	Get a new, empty page for the given column that can be filled with up to nElements.

void	UpdateExtraTypeInfo (const RExtraTypeInfoDescriptor &) final
	Adds an extra type information record to schema.

void	UpdateSchema (const RNTupleModelChangeset &changeset, NTupleSize_t firstEntry) final
	Incorporate incremental changes to the model into the ntuple descriptor.

Public Member Functions inherited from ROOT::Experimental::Internal::RPageSink
	RPageSink (const RPageSink &)=delete

	RPageSink (RPageSink &&)=default

	RPageSink (std::string_view ntupleName, const RNTupleWriteOptions &options)

	~RPageSink () override

void	CommitDataset ()
	Run the registered callbacks and finalize the current cluster and the entrire data set.

void	DropColumn (ColumnHandle_t) final
	Unregisters a column.

virtual RSinkGuard	GetSinkGuard ()

EPageStorageType	GetType () final
	Whether the concrete implementation is a sink or a source.

const RNTupleWriteOptions &	GetWriteOptions () const
	Returns the sink's write options.

void	Init (RNTupleModel &model)
	Physically creates the storage container to hold the ntuple (e.g., a keys a TFile or an S3 bucket) Init() associates column handles to the columns referenced by the model.

bool	IsInitialized () const

RPageSink &	operator= (const RPageSink &)=delete

RPageSink &	operator= (RPageSink &&)=default

void	RegisterOnCommitDatasetCallback (Callback_t callback)
	The registered callback is executed at the beginning of CommitDataset();.

Public Member Functions inherited from ROOT::Experimental::Internal::RPageStorage
	RPageStorage (const RPageStorage &other)=delete

	RPageStorage (RPageStorage &&other)=default

	RPageStorage (std::string_view name)

virtual	~RPageStorage ()

virtual Detail::RNTupleMetrics &	GetMetrics ()
	Returns the default metrics object.

const std::string &	GetNTupleName () const
	Returns the NTuple name.

RPageStorage &	operator= (const RPageStorage &other)=delete

RPageStorage &	operator= (RPageStorage &&other)=default

void	SetTaskScheduler (RTaskScheduler *taskScheduler)

Private Attributes
std::uint64_t	fNBytesCurrentCluster = 0

DescriptorId_t	fNColumns = 0

RPageAllocatorHeap	fPageAllocator {}

Additional Inherited Members
Public Types inherited from ROOT::Experimental::Internal::RPageSink
using	Callback_t = std::function< void(RPageSink &)>

Public Types inherited from ROOT::Experimental::Internal::RPageStorage
using	ColumnHandle_t = RColumnHandle
	The column handle identifies a column with the current open page storage.

using	SealedPageSequence_t = std::deque< RSealedPage >

Protected Member Functions inherited from ROOT::Experimental::Internal::RPageSink
RSealedPage	SealPage (const RPage &page, const RColumnElementBase &element)
	Helper for streaming a page.

Protected Member Functions inherited from ROOT::Experimental::Internal::RPageStorage
void	WaitForAllTasks ()

Static Protected Member Functions inherited from ROOT::Experimental::Internal::RPageSink
static RSealedPage	SealPage (const RPage &page, const RColumnElementBase &element, int compressionSetting, void *buf, bool allowAlias=true)
	Seal a page using the provided buffer.

Protected Attributes inherited from ROOT::Experimental::Internal::RPageSink
std::unique_ptr< RNTupleCompressor >	fCompressor
	Helper to zip pages and header/footer; includes a 16MB (kMAXZIPBUF) zip buffer.

std::unique_ptr< RNTupleWriteOptions >	fOptions

Protected Attributes inherited from ROOT::Experimental::Internal::RPageStorage
Detail::RNTupleMetrics	fMetrics

std::string	fNTupleName

RTaskScheduler *	fTaskScheduler = nullptr

#include <ROOT/RPageNullSink.hxx>

Inheritance diagram for ROOT::Experimental::Internal::RPageNullSink:

[legend]

Constructor & Destructor Documentation

◆ RPageNullSink()

ROOT::Experimental::Internal::RPageNullSink::RPageNullSink	(	std::string_view	ntupleName,
		const RNTupleWriteOptions &	options
	)

inline

Definition at line 42 of file RPageNullSink.hxx.

Member Function Documentation

◆ AddColumn()

ColumnHandle_t ROOT::Experimental::Internal::RPageNullSink::AddColumn	(	DescriptorId_t	fieldId,
		const RColumn &	column
	)

inlinefinalvirtual

Register a new column.

When reading, the column must exist in the ntuple on disk corresponding to the meta-data. When writing, every column can only be attached once.

Implements ROOT::Experimental::Internal::RPageStorage.

Definition at line 44 of file RPageNullSink.hxx.

◆ CommitCluster()

std::uint64_t ROOT::Experimental::Internal::RPageNullSink::CommitCluster ( NTupleSize_t nNewEntries )

inlinefinalvirtual

Finalize the current cluster and create a new one for the following data.

Returns the number of bytes written to storage (excluding meta-data).

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 87 of file RPageNullSink.hxx.

◆ CommitClusterGroup()

void ROOT::Experimental::Internal::RPageNullSink::CommitClusterGroup ( )

inlinefinalvirtual

Write out the page locations (page list envelope) for all the committed clusters since the last call of CommitClusterGroup (or the beginning of writing).

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 93 of file RPageNullSink.hxx.

◆ CommitDatasetImpl()

void ROOT::Experimental::Internal::RPageNullSink::CommitDatasetImpl ( )

inlinefinalvirtual

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 94 of file RPageNullSink.hxx.

◆ CommitPage()

void ROOT::Experimental::Internal::RPageNullSink::CommitPage	(	ColumnHandle_t	columnHandle,
		const RPage &	page
	)

inlinefinalvirtual

Write a page to the storage. The column must have been added before.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 76 of file RPageNullSink.hxx.

◆ CommitSealedPage()

void ROOT::Experimental::Internal::RPageNullSink::CommitSealedPage	(	DescriptorId_t	physicalColumnId,
		const RSealedPage &	sealedPage
	)

inlinefinalvirtual

Write a preprocessed page to storage. The column must have been added before.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 77 of file RPageNullSink.hxx.

◆ CommitSealedPageV()

void ROOT::Experimental::Internal::RPageNullSink::CommitSealedPageV ( std::span< RSealedPageGroup > ranges )

inlinefinalvirtual

Write a vector of preprocessed pages to storage. The corresponding columns must have been added before.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 78 of file RPageNullSink.hxx.

◆ ConnectFields()

void ROOT::Experimental::Internal::RPageNullSink::ConnectFields	(	const std::vector< RFieldBase * > &	fields,
		NTupleSize_t	firstEntry
	)

inline

Definition at line 59 of file RPageNullSink.hxx.

◆ GetDescriptor()

const RNTupleDescriptor & ROOT::Experimental::Internal::RPageNullSink::GetDescriptor ( ) const

inlinefinalvirtual

Return the RNTupleDescriptor being constructed.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 53 of file RPageNullSink.hxx.

◆ InitImpl()

void ROOT::Experimental::Internal::RPageNullSink::InitImpl ( RNTupleModel & model )

inlinefinalvirtual

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 69 of file RPageNullSink.hxx.

◆ ReleasePage()

void ROOT::Experimental::Internal::RPageNullSink::ReleasePage ( RPage & page )

inlinefinalvirtual

Every page store needs to be able to free pages it handed out.

But Sinks and sources have different means of allocating pages.

Implements ROOT::Experimental::Internal::RPageStorage.

Definition at line 51 of file RPageNullSink.hxx.

◆ ReservePage()

RPage ROOT::Experimental::Internal::RPageNullSink::ReservePage	(	ColumnHandle_t	columnHandle,
		std::size_t	nElements
	)

inlinefinalvirtual

Get a new, empty page for the given column that can be filled with up to nElements.

If nElements is zero, the page sink picks an appropriate size.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 46 of file RPageNullSink.hxx.

◆ UpdateExtraTypeInfo()

void ROOT::Experimental::Internal::RPageNullSink::UpdateExtraTypeInfo ( const RExtraTypeInfoDescriptor & extraTypeInfo )

inlinefinalvirtual

Adds an extra type information record to schema.

The extra type information will be written to the extension header. The information in the record will be merged with the existing information, e.g. duplicate streamer info records will be removed. This method is called by the "on commit dataset" callback registered by specific fields (e.g., unsplit field) and during merging.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 74 of file RPageNullSink.hxx.

◆ UpdateSchema()

void ROOT::Experimental::Internal::RPageNullSink::UpdateSchema	(	const RNTupleModelChangeset &	changeset,
		NTupleSize_t	firstEntry
	)

inlinefinalvirtual

Incorporate incremental changes to the model into the ntuple descriptor.

This happens, e.g. if new fields were added after the initial call to RPageSink::Init(RNTupleModel &). firstEntry specifies the global index for the first stored element in the added columns.

Implements ROOT::Experimental::Internal::RPageSink.

Definition at line 70 of file RPageNullSink.hxx.

Member Data Documentation

◆ fNBytesCurrentCluster

std::uint64_t ROOT::Experimental::Internal::RPageNullSink::fNBytesCurrentCluster = 0

private

Definition at line 39 of file RPageNullSink.hxx.

◆ fNColumns

DescriptorId_t ROOT::Experimental::Internal::RPageNullSink::fNColumns = 0

private

Definition at line 38 of file RPageNullSink.hxx.

◆ fPageAllocator

RPageAllocatorHeap ROOT::Experimental::Internal::RPageNullSink::fPageAllocator {}

private

Definition at line 37 of file RPageNullSink.hxx.

Libraries for ROOT::Experimental::Internal::RPageNullSink:

[legend]

The documentation for this class was generated from the following file:

tree/ntuple/v7/inc/ROOT/RPageNullSink.hxx

Public Member Functions

Private Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ RPageNullSink()

Member Function Documentation

◆ AddColumn()

◆ CommitCluster()

◆ CommitClusterGroup()

◆ CommitDatasetImpl()

◆ CommitPage()

◆ CommitSealedPage()

◆ CommitSealedPageV()

◆ ConnectFields()

◆ GetDescriptor()

◆ InitImpl()

◆ ReleasePage()

◆ ReservePage()

◆ UpdateExtraTypeInfo()

◆ UpdateSchema()

Member Data Documentation

◆ fNBytesCurrentCluster

◆ fNColumns

◆ fPageAllocator