Enum MaybeEncoded 

pub enum MaybeEncoded<T> {
    Encoded(Vec<u8>),
    Decoded(T),
}

A value that a transport may either leave encoded or materialize in memory. Users are free to pass MaybeEncoded::Encoded or MaybeEncoded::Decoded at any moment and Distributed DataFusion’s code will internally know how to handle it.

Variants

Encoded(Vec<u8>)

Decoded(T)

Implementations

impl MaybeEncoded<Arc<dyn ExecutionPlan>>

pub fn encode(self, ctx: &Arc<TaskContext>) -> Result<Vec<u8>>

Returns the encoded ExecutionPlan as protobuf bytes:

• If in Decoded state, it encodes it using the codecs registered in the TaskContext.
• If in Encoded state, it just passes through the content.

impl MaybeEncoded<Partitioning>

pub fn encode(self, ctx: &Arc<TaskContext>) -> Result<Vec<u8>>

Returns the encoded Partitioning as protobuf bytes:

• If in Decoded state, it encodes it using the codecs registered in the TaskContext.
• If in Encoded state, it just passes through the content.

pub fn decode( self, schema: SchemaRef, task_ctx: &TaskContext, ) -> Result<Partitioning>

Returns the decoded Partitioning.

• If in Decoded state, it just passes through the content.
• If in Encoded state, it decodes it using the codecs registered in the TaskContext.

Trait Implementations

impl<T: Clone> Clone for MaybeEncoded<T>

fn clone(&self) -> MaybeEncoded<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.