Project
Loading...
Searching...
No Matches
o2::framework::ArrowTableSlicingCache Struct Reference

#include <ArrowTableSlicingCache.h>

Public Member Functions

 ArrowTableSlicingCache (Cache &&bsks, Cache &&bsksUnsorted={})
 
void setCaches (Cache &&bsks, Cache &&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 (Entry const &bindingKey) const
 
int getCachePosSortedFor (Entry const &bindingKey) const
 
int getCachePosUnsortedFor (Entry const &bindingKey) const
 
SliceInfoPtr getCacheFor (Entry const &bindingKey) const
 
SliceInfoUnsortedPtr getCacheUnsortedFor (Entry const &bindingKey) const
 
SliceInfoPtr getCacheForPos (int pos) const
 
SliceInfoUnsortedPtr getCacheUnsortedForPos (int pos) const
 

Static Public Member Functions

static void validateOrder (Entry const &bindingKey, std::shared_ptr< arrow::Table > const &input)
 

Public Attributes

Cache bindingsKeys
 
std::vector< std::shared_ptr< arrow::NumericArray< arrow::Int32Type > > > values
 
std::vector< std::shared_ptr< arrow::NumericArray< arrow::Int64Type > > > counts
 
Cache bindingsKeysUnsorted
 
std::vector< std::vector< int > > valuesUnsorted
 
std::vector< ListVectorgroups
 

Static Public Attributes

static constexpr ServiceKind service_kind = ServiceKind::Stream
 

Detailed Description

Definition at line 63 of file ArrowTableSlicingCache.h.

Constructor & Destructor Documentation

◆ ArrowTableSlicingCache()

o2::framework::ArrowTableSlicingCache::ArrowTableSlicingCache ( Cache &&  bsks,
Cache &&  bsksUnsorted = {} 
)

Definition at line 81 of file ArrowTableSlicingCache.cxx.

Member Function Documentation

◆ getCacheFor()

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

Definition at line 194 of file ArrowTableSlicingCache.cxx.

◆ getCacheForPos()

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

Definition at line 220 of file ArrowTableSlicingCache.cxx.

◆ getCachePos()

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

Definition at line 164 of file ArrowTableSlicingCache.cxx.

◆ getCachePosSortedFor()

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

Definition at line 177 of file ArrowTableSlicingCache.cxx.

◆ getCachePosUnsortedFor()

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

Definition at line 186 of file ArrowTableSlicingCache.cxx.

◆ getCacheUnsortedFor()

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

Definition at line 207 of file ArrowTableSlicingCache.cxx.

◆ getCacheUnsortedForPos()

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

Definition at line 235 of file ArrowTableSlicingCache.cxx.

◆ setCaches()

void o2::framework::ArrowTableSlicingCache::setCaches ( Cache &&  bsks,
Cache &&  bsksUnsorted = {} 
)

Definition at line 92 of file ArrowTableSlicingCache.cxx.

◆ updateCacheEntry()

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

Definition at line 106 of file ArrowTableSlicingCache.cxx.

◆ updateCacheEntryUnsorted()

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

Definition at line 131 of file ArrowTableSlicingCache.cxx.

◆ validateOrder()

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

Definition at line 243 of file ArrowTableSlicingCache.cxx.

Member Data Documentation

◆ bindingsKeys

Cache o2::framework::ArrowTableSlicingCache::bindingsKeys

Definition at line 66 of file ArrowTableSlicingCache.h.

◆ bindingsKeysUnsorted

Cache o2::framework::ArrowTableSlicingCache::bindingsKeysUnsorted

Definition at line 70 of file ArrowTableSlicingCache.h.

◆ counts

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

Definition at line 68 of file ArrowTableSlicingCache.h.

◆ groups

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

Definition at line 72 of file ArrowTableSlicingCache.h.

◆ service_kind

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

Definition at line 64 of file ArrowTableSlicingCache.h.

◆ values

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

Definition at line 67 of file ArrowTableSlicingCache.h.

◆ valuesUnsorted

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

Definition at line 71 of file ArrowTableSlicingCache.h.


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