Struct ArrowBatchCache

pub struct ArrowBatchCache {
    pub table_cache: Cache<String, Arc<RecordBatch>>,
    pub metadata_cache: Cache<u64, ArrowBatchFileMetadata>,
    /* private fields */
}

Fields

table_cache: Cache<String, Arc<RecordBatch>>

metadata_cache: Cache<u64, ArrowBatchFileMetadata>

Implementations

impl ArrowBatchCache

pub fn new(context: Arc<Mutex<ArrowBatchContext>>) -> Self

pub fn get_metadata_for( &self, adjusted_ordinal: u64, locked_context: Option<Arc<MutexGuard<'_, ArrowBatchContext>>>, ) -> u64

pub fn direct_load_table( &self, adjusted_ordinal: u64, batch_index: usize, locked_context: Option<Arc<MutexGuard<'_, ArrowBatchContext>>>, ) -> Option<RecordBatch>

pub fn get_table_for( &self, ordinal: u64, locked_context: Option<Arc<MutexGuard<'_, ArrowBatchContext>>>, ) -> Option<Arc<RecordBatch>>