Struct TableMsg 

pub struct TableMsg {
    pub id: TableId,
    pub data: RecordBatch,
}

A table, encoded as a dataframe of Arrow record batches.

Tables have a TableId, but don’t belong to an application and therefore don’t have an ApplicationId. For now, the table is always sent as a whole, i.e. tables can’t be streamed.

It’s important to note that tables are not sent via the smart channel of LogMsg, but use a separate crossbeam channel. The reasoning behind this is that tables are fundamentally different from recordings. For example, we don’t want to store tables in .rrd files, as there are much better formats out there.

Fields

id: TableId

The id of the table.

data: RecordBatch

The table stored as an ArrowRecordBatch.

Implementations

impl TableMsg

pub fn insert_arrow_record_batch_metadata(&mut self, key: String, value: String)

Trait Implementations

impl Clone for TableMsg

fn clone(&self) -> TableMsg

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TableMsg

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for TableMsg

fn eq(&self, other: &TableMsg) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl SizeBytes for TableMsg

fn heap_size_bytes(&self) -> u64

Returns how many bytes self uses on the heap.

fn total_size_bytes(&self) -> u64

Returns the total size of self in bytes, accounting for both stack and heap space.

fn stack_size_bytes(&self) -> u64

Returns the total size of self on the stack, in bytes.

fn is_pod() -> bool

Is Self just plain old data?

impl StructuralPartialEq for TableMsg