Struct arrowbatch::reader::ArrowBatchContext

pub struct ArrowBatchContext {
    pub config: ArrowBatchConfig,
    pub data_definition: ArrowBatchContextDef,
    pub alias: String,
    pub ordinal_index: usize,
    pub table_file_map: TableFileMap,
    pub table_mapping: TableMapping,
    pub wip_file: Option<String>,
    pub first_ordinal: Option<u64>,
    pub last_ordinal: Option<u64>,
}

Fields

config: ArrowBatchConfig

data_definition: ArrowBatchContextDef

alias: String

ordinal_index: usize

table_file_map: TableFileMap

table_mapping: TableMapping

wip_file: Option<String>

first_ordinal: Option<u64>

last_ordinal: Option<u64>

Implementations

impl ArrowBatchContext

pub fn new(config: ArrowBatchConfig) -> Arc<Mutex<Self>>

pub fn get_ordinal(&self, ordinal: u64) -> u64

pub fn get_ordinal_suffix(&self, ordinal: u64) -> String

pub fn bucket_to_ordinal(&self, table_bucket_name: &String) -> Option<u64>

pub fn reload_on_disk_buckets(&mut self)