ArrowTable.h File Reference

#include "AODNative/Decoder.h"
#include "AODNative/Objects.h"
#include <arrow/memory_pool.h>
#include <arrow/record_batch.h>
#include <arrow/result.h>
#include <arrow/type.h>
#include <memory>
#include <vector>

Go to the source code of this file.

Classes
struct	o2::aod::native::ColumnOp

Namespaces
namespace	o2
	a couple of static helper functions to create timestamp values for CCDB queries or override obsolete objects
namespace	o2::aod
namespace	o2::aod::native

Functions
std::shared_ptr< arrow::Schema >	o2::aod::native::physicalSchema (TreeInfo const &tree)
std::shared_ptr< arrow::Schema >	o2::aod::native::datasetSchema (std::shared_ptr< arrow::Schema > const &physical)
	The physical schema without the *_size fields, as DataInputDirector derives it.
std::vector< ColumnOp >	o2::aod::native::planColumns (TreeInfo const &tree, std::shared_ptr< arrow::Schema > const &schema, BranchDecoder &decoder, arrow::MemoryPool *pool, int64_t &rows)
void	o2::aod::native::executeColumnOp (BranchDecoder &decoder, ColumnOp const &op, uint8_t *dst)
	Fills the buffer of op, which is exactly op.byteSize bytes.
std::shared_ptr< arrow::RecordBatch >	o2::aod::native::makeBatch (std::shared_ptr< arrow::Schema > const &schema, std::vector< ColumnOp > const &ops, std::vector< std::shared_ptr< arrow::Buffer > > const &buffers, int64_t rows)
	Wraps the buffers of ops (one per op, in order) into a record batch.
arrow::Result< std::shared_ptr< arrow::RecordBatch > >	o2::aod::native::readTree (ByteSource &source, TreeInfo const &tree, Options const &options, arrow::MemoryPool *pool=arrow::default_memory_pool())
	Reads a whole tree into heap memory: plan, execute, wrap.