Struct CustomData 

pub struct CustomData {
    pub data: Arc<dyn CustomDataTrait>,
    pub data_type: DataType,
}

A wrapper for custom data including its data type.

The data field holds an Arc to a CustomDataTrait implementation, enabling cheap cloning when passing to Python (Arc clone is O(1)). Custom data is always Rust-defined (optionally with PyO3 bindings).

Fields

data: Arc<dyn CustomDataTrait>

The actual data object implementing CustomDataTrait.

data_type: DataType

The data type metadata.

Implementations

impl CustomData

pub fn from_arc(arc: Arc<dyn CustomDataTrait>) -> Self

Creates a new CustomData instance from an Arc’d CustomDataTrait, deriving the data type from the inner type name.

pub fn new(data: Arc<dyn CustomDataTrait>, data_type: DataType) -> Self

Creates a new CustomData instance with explicit data type metadata.

Use this when the data type must come from external metadata (e.g. Parquet), rather than being derived from the inner type name.

impl CustomData

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

Deserializes CustomData from JSON bytes (full CustomData format with type and data_type).

Errors

Returns an error if the bytes are not valid JSON or do not represent CustomData.

Trait Implementations

impl Clone for CustomData

fn clone(&self) -> CustomData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CustomData

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

Formats the value using the given formatter.

impl HasTsInit for CustomData

fn ts_init(&self) -> UnixNanos

Returns the UNIX timestamp (nanoseconds) when the instance was created.

impl PartialEq for CustomData

fn eq(&self, other: &Self) -> 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 Serialize for CustomData

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.