Struct MaterializedViewUdtfEntry 

pub struct MaterializedViewUdtfEntry {

    pub kind: Kind,
    pub udtf: String,
    pub udtf_sha: String,
    pub udtf_name: String,
    pub udtf_version: String,
    pub input_columns: Option<Option<Vec<String>>>,
    pub partition_by: Option<Option<String>>,
    pub partition_by_indexed_column: Option<Option<String>>,
    pub num_cpus: Option<Option<f64>>,
    pub num_gpus: Option<Option<f64>>,
    pub memory: Option<Option<i32>>,
    pub error_handling: Option<Option<Value>>,
    pub batch: Option<Option<bool>>,
    pub manifest: Option<Option<String>>,
    pub manifest_checksum: Option<Option<String>>,
}

Fields

kind: Kind

Discriminates a batch UDTF (udtf, full-overwrite refresh) from a chunker (chunker, incremental 1:N refresh). Must match the enclosing request’s kind.

udtf: String

Base64-encoded UDTFSpec / ChunkerSpec JSON envelope (per kind).

udtf_sha: String

SHA-256 checksum of the envelope; server validates.

udtf_name: String

Name of the UDTF

udtf_version: String

Version of the UDTF

input_columns: Option<Option<Vec<String>>>

Source columns the UDTF reads. Null means all columns (batch UDTF only).

partition_by: Option<Option<String>>

Batch UDTF only. Column-value partition key for partition-parallel execution. Mutually exclusive with partition_by_indexed_column.

partition_by_indexed_column: Option<Option<String>>

Batch UDTF only. Source column with an IVF-family index used for index-based partitioning. The server validates the index exists at create time.

num_cpus: Option<Option<f64>>

Ray actor CPU request.

num_gpus: Option<Option<f64>>

Ray actor GPU request.

memory: Option<Option<i32>>

Ray actor memory request, in bytes.

error_handling: Option<Option<Value>>

Batch UDTF only. Serialized ErrorHandlingConfig controlling partition-grain fail/retry/skip behavior.

batch: Option<Option<bool>>

Chunker only. True for a batched chunker; affects how the worker dispatches input rows.

manifest: Option<Option<String>>

JSON-serialized GenevaManifest for the UDTF environment.

manifest_checksum: Option<Option<String>>

SHA-256 checksum of the manifest content.

Implementations

impl MaterializedViewUdtfEntry

pub fn new( kind: Kind, udtf: String, udtf_sha: String, udtf_name: String, udtf_version: String, ) -> MaterializedViewUdtfEntry

Trait Implementations

impl Clone for MaterializedViewUdtfEntry

fn clone(&self) -> MaterializedViewUdtfEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MaterializedViewUdtfEntry

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

Formats the value using the given formatter.

impl Default for MaterializedViewUdtfEntry

fn default() -> MaterializedViewUdtfEntry

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MaterializedViewUdtfEntry

fn deserialize<__D>( __deserializer: __D, ) -> Result<MaterializedViewUdtfEntry, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MaterializedViewUdtfEntry

fn eq(&self, other: &MaterializedViewUdtfEntry) -> 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 MaterializedViewUdtfEntry

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MaterializedViewUdtfEntry