Struct ArrowTensorStore 

pub struct ArrowTensorStore { /* private fields */ }

Collection of tensors stored in Arrow format

Implementations

impl ArrowTensorStore

pub fn new() -> Self

Create a new empty store

pub fn insert(&mut self, tensor: ArrowTensor)

Add a tensor to the store

pub fn get(&self, name: &str) -> Option<&ArrowTensor>

Get a tensor by name

pub fn names(&self) -> Vec<&str>

List all tensor names

pub fn len(&self) -> usize

Get the number of tensors

pub fn is_empty(&self) -> bool

Check if empty

pub fn build_schema(&mut self) -> Arc<Schema>

Build Arrow schema for all tensors

pub fn to_record_batch(&mut self) -> Result<RecordBatch, ArrowError>

Convert to RecordBatch for IPC

pub fn write_ipc<W: Write>(&mut self, writer: W) -> Result<(), ArrowError>

Write to Arrow IPC format

pub fn read_ipc<R: Read + Seek>(reader: R) -> Result<Self, ArrowError>

Read from Arrow IPC format

pub fn to_bytes(&mut self) -> Result<Bytes, ArrowError>

Serialize to bytes (Arrow IPC format)

pub fn from_bytes(bytes: &[u8]) -> Result<Self, ArrowError>

Deserialize from bytes

Trait Implementations

impl Default for ArrowTensorStore

fn default() -> Self

Returns the “default value” for a type.