Project
Loading...
Searching...
No Matches
o2::framework::NativeAODDeferredReadOutputStream Class Reference

Inherits arrow::io::OutputStream.

Public Member Functions

 NativeAODDeferredReadOutputStream (std::shared_ptr< NativeAODFileFragment > fragment, const std::shared_ptr< arrow::ResizableBuffer > &buffer)
 
 ~NativeAODDeferredReadOutputStream () override=default
 
arrow::Status Close () override
 
bool closed () const override
 
arrow::Result< int64_t > Tell () const override
 
arrow::Status Write (const void *data, int64_t nbytes) override
 

Detailed Description

An OutputStream which does the reading of the input buffers directly on writing, if needed. Each deferred operation is encoded in the source buffer by an incremental number which can be used to lookup in the fragment's ops the operation to perform.

Definition at line 88 of file NativeAODPlugin.cxx.

Constructor & Destructor Documentation

◆ NativeAODDeferredReadOutputStream()

o2::framework::NativeAODDeferredReadOutputStream::NativeAODDeferredReadOutputStream ( std::shared_ptr< NativeAODFileFragment >  fragment,
const std::shared_ptr< arrow::ResizableBuffer > &  buffer 
)
inline

Definition at line 91 of file NativeAODPlugin.cxx.

◆ ~NativeAODDeferredReadOutputStream()

o2::framework::NativeAODDeferredReadOutputStream::~NativeAODDeferredReadOutputStream ( )
overridedefault

Member Function Documentation

◆ Close()

arrow::Status o2::framework::NativeAODDeferredReadOutputStream::Close ( )
inlineoverride

Definition at line 107 of file NativeAODPlugin.cxx.

◆ closed()

bool o2::framework::NativeAODDeferredReadOutputStream::closed ( ) const
inlineoverride

Definition at line 118 of file NativeAODPlugin.cxx.

◆ Tell()

arrow::Result< int64_t > o2::framework::NativeAODDeferredReadOutputStream::Tell ( ) const
inlineoverride

Definition at line 119 of file NativeAODPlugin.cxx.

◆ Write()

arrow::Status o2::framework::NativeAODDeferredReadOutputStream::Write ( const void *  data,
int64_t  nbytes 
)
inlineoverride

Definition at line 121 of file NativeAODPlugin.cxx.


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