#include <ArrowTableSlicingCache.h>

Public Member Functions
	ArrowTableSlicingCache (std::vector< StringPair > &&bsks, std::vector< StringPair > &&bsksUnsorted={})

void	setCaches (std::vector< StringPair > &&bsks, std::vector< StringPair > &&bsksUnsorted={})

arrow::Status	updateCacheEntry (int pos, std::shared_ptr< arrow::Table > const &table)

arrow::Status	updateCacheEntryUnsorted (int pos, std::shared_ptr< arrow::Table > const &table)

std::pair< int, bool >	getCachePos (StringPair const &bindingKey) const

int	getCachePosSortedFor (StringPair const &bindingKey) const

int	getCachePosUnsortedFor (StringPair const &bindingKey) const

SliceInfoPtr	getCacheFor (StringPair const &bindingKey) const

SliceInfoUnsortedPtr	getCacheUnsortedFor (StringPair const &bindingKey) const

SliceInfoPtr	getCacheForPos (int pos) const

SliceInfoUnsortedPtr	getCacheUnsortedForPos (int pos) const

Static Public Member Functions
static void	validateOrder (StringPair const &bindingKey, std::shared_ptr< arrow::Table > const &input)

Public Attributes
std::vector< StringPair >	bindingsKeys

std::vector< std::shared_ptr< arrow::NumericArray< arrow::Int32Type > > >	values

std::vector< std::shared_ptr< arrow::NumericArray< arrow::Int64Type > > >	counts

std::vector< StringPair >	bindingsKeysUnsorted

std::vector< std::vector< int > >	valuesUnsorted

std::vector< ListVector >	groups

Static Public Attributes
static constexpr ServiceKind	service_kind = ServiceKind::Stream

Detailed Description

Definition at line 50 of file ArrowTableSlicingCache.h.

Constructor & Destructor Documentation

◆ ArrowTableSlicingCache()

o2::framework::ArrowTableSlicingCache::ArrowTableSlicingCache	(	std::vector< StringPair > &&	bsks,
		std::vector< StringPair > &&	bsksUnsorted = `{}`
	)

Definition at line 78 of file ArrowTableSlicingCache.cxx.

Member Function Documentation

◆ getCacheFor()

SliceInfoPtr o2::framework::ArrowTableSlicingCache::getCacheFor ( StringPair const & bindingKey ) const

Definition at line 184 of file ArrowTableSlicingCache.cxx.

◆ getCacheForPos()

SliceInfoPtr o2::framework::ArrowTableSlicingCache::getCacheForPos ( int pos ) const

Definition at line 204 of file ArrowTableSlicingCache.cxx.

◆ getCachePos()

std::pair< int, bool > o2::framework::ArrowTableSlicingCache::getCachePos ( StringPair const & bindingKey ) const

Definition at line 154 of file ArrowTableSlicingCache.cxx.

◆ getCachePosSortedFor()

int o2::framework::ArrowTableSlicingCache::getCachePosSortedFor ( StringPair const & bindingKey ) const

Definition at line 167 of file ArrowTableSlicingCache.cxx.

◆ getCachePosUnsortedFor()

int o2::framework::ArrowTableSlicingCache::getCachePosUnsortedFor ( StringPair const & bindingKey ) const

Definition at line 176 of file ArrowTableSlicingCache.cxx.

◆ getCacheUnsortedFor()

SliceInfoUnsortedPtr o2::framework::ArrowTableSlicingCache::getCacheUnsortedFor ( StringPair const & bindingKey ) const

Definition at line 194 of file ArrowTableSlicingCache.cxx.

◆ getCacheUnsortedForPos()

SliceInfoUnsortedPtr o2::framework::ArrowTableSlicingCache::getCacheUnsortedForPos ( int pos ) const

Definition at line 219 of file ArrowTableSlicingCache.cxx.

◆ setCaches()

void o2::framework::ArrowTableSlicingCache::setCaches	(	std::vector< StringPair > &&	bsks,
		std::vector< StringPair > &&	bsksUnsorted = `{}`
	)

Definition at line 89 of file ArrowTableSlicingCache.cxx.

◆ updateCacheEntry()

arrow::Status o2::framework::ArrowTableSlicingCache::updateCacheEntry	(	int	pos,
		std::shared_ptr< arrow::Table > const &	table
	)

Definition at line 103 of file ArrowTableSlicingCache.cxx.

◆ updateCacheEntryUnsorted()

arrow::Status o2::framework::ArrowTableSlicingCache::updateCacheEntryUnsorted	(	int	pos,
		std::shared_ptr< arrow::Table > const &	table
	)

Definition at line 124 of file ArrowTableSlicingCache.cxx.

◆ validateOrder()

void o2::framework::ArrowTableSlicingCache::validateOrder	(	StringPair const &	bindingKey,
		std::shared_ptr< arrow::Table > const &	input
	)

static

Definition at line 227 of file ArrowTableSlicingCache.cxx.

Member Data Documentation

◆ bindingsKeys

std::vector<StringPair> o2::framework::ArrowTableSlicingCache::bindingsKeys

Definition at line 53 of file ArrowTableSlicingCache.h.

◆ bindingsKeysUnsorted

std::vector<StringPair> o2::framework::ArrowTableSlicingCache::bindingsKeysUnsorted

Definition at line 57 of file ArrowTableSlicingCache.h.

◆ counts

std::vector<std::shared_ptr<arrow::NumericArray<arrow::Int64Type> > > o2::framework::ArrowTableSlicingCache::counts

Definition at line 55 of file ArrowTableSlicingCache.h.

◆ groups

std::vector<ListVector> o2::framework::ArrowTableSlicingCache::groups

Definition at line 59 of file ArrowTableSlicingCache.h.

◆ service_kind

constexpr ServiceKind o2::framework::ArrowTableSlicingCache::service_kind = ServiceKind::Stream

staticconstexpr

Definition at line 51 of file ArrowTableSlicingCache.h.

◆ values

std::vector<std::shared_ptr<arrow::NumericArray<arrow::Int32Type> > > o2::framework::ArrowTableSlicingCache::values

Definition at line 54 of file ArrowTableSlicingCache.h.

◆ valuesUnsorted

std::vector<std::vector<int> > o2::framework::ArrowTableSlicingCache::valuesUnsorted

Definition at line 58 of file ArrowTableSlicingCache.h.

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

/home/runner/work/AliceO2/AliceO2/Framework/Core/include/Framework/ArrowTableSlicingCache.h
/home/runner/work/AliceO2/AliceO2/Framework/Core/src/ArrowTableSlicingCache.cxx

Public Member Functions

Static Public Member Functions

Public Attributes

Static Public Attributes