Project
Loading...
Searching...
No Matches
Public Types | Public Member Functions | List of all members
o2::framework::FragmentToBatch Class Reference

#include <TableTreeHelpers.h>

Public Types

using StreamerCreator = std::function< std::shared_ptr< arrow::io::OutputStream >(std::shared_ptr< arrow::dataset::FileFragment >, const std::shared_ptr< arrow::ResizableBuffer > &buffer)>
 

Public Member Functions

 FragmentToBatch (StreamerCreator, std::shared_ptr< arrow::dataset::FileFragment >, arrow::MemoryPool *pool=arrow::default_memory_pool())
 
void setLabel (const char *label)
 
void fill (std::shared_ptr< arrow::Schema > dataSetSchema, std::shared_ptr< arrow::dataset::FileFormat >)
 
std::shared_ptr< arrow::RecordBatch > finalize ()
 
std::shared_ptr< arrow::io::OutputStream > streamer (std::shared_ptr< arrow::ResizableBuffer > buffer)
 

Detailed Description

Definition at line 94 of file TableTreeHelpers.h.

Member Typedef Documentation

◆ StreamerCreator

using o2::framework::FragmentToBatch::StreamerCreator = std::function<std::shared_ptr<arrow::io::OutputStream>(std::shared_ptr<arrow::dataset::FileFragment>, const std::shared_ptr<arrow::ResizableBuffer>& buffer)>

Definition at line 98 of file TableTreeHelpers.h.

Constructor & Destructor Documentation

◆ FragmentToBatch()

o2::framework::FragmentToBatch::FragmentToBatch ( StreamerCreator  creator,
std::shared_ptr< arrow::dataset::FileFragment >  fragment,
arrow::MemoryPool *  pool = arrow::default_memory_pool() 
)

Definition at line 299 of file TableTreeHelpers.cxx.

Member Function Documentation

◆ fill()

void o2::framework::FragmentToBatch::fill ( std::shared_ptr< arrow::Schema >  dataSetSchema,
std::shared_ptr< arrow::dataset::FileFormat >  format 
)

Definition at line 311 of file TableTreeHelpers.cxx.

◆ finalize()

std::shared_ptr< arrow::RecordBatch > o2::framework::FragmentToBatch::finalize ( )

Definition at line 321 of file TableTreeHelpers.cxx.

◆ setLabel()

void o2::framework::FragmentToBatch::setLabel ( const char *  label)

Definition at line 306 of file TableTreeHelpers.cxx.

◆ streamer()

std::shared_ptr< arrow::io::OutputStream > o2::framework::FragmentToBatch::streamer ( std::shared_ptr< arrow::ResizableBuffer >  buffer)
inline

Definition at line 105 of file TableTreeHelpers.h.

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