ArrowTable.cxx File Reference

#include "AODNative/ArrowTable.h"
#include "AODNative/Errors.h"
#include <arrow/array/array_nested.h>
#include <arrow/array/util.h>
#include <arrow/buffer.h>
#include <cstdio>
#include <cstring>

Go to the source code of this file.

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.