Struct MaterializeConfig 

pub struct MaterializeConfig {
    pub mode: MaterializeMode,
    pub ref_strategy: RefStrategy,
    pub memtable_max_rows: usize,
    pub max_row_group_rows: usize,
    pub max_row_group_bytes: usize,
    pub iceberg: IcebergConfig,
    pub wap: bool,
}

Optional materialization / ref() registration policy (materialize: in yml).

All fields are optional; omitting the whole block keeps lake-as-truth Parquet re-read and stream write mode.

Fields

mode: MaterializeMode

stream (default) | collect

ref_strategy: RefStrategy

parquet (default) | memtable

memtable_max_rows: usize

Used only when ref_strategy: memtable. Defaults to DEFAULT_MEMTABLE_MAX_ROWS.

max_row_group_rows: usize

Parquet WriterProperties max rows per row group (stream + collect writers).

max_row_group_bytes: usize

Soft flush threshold for Parquet in_progress_size (bytes).

iceberg: IcebergConfig

Iceberg catalog vs filesystem layout.

wap: bool

Write-Audit-Publish: stage under .wap/{run_id}/, audit, then atomic publish. Default false (stream still uses partial→rename atomicity without WAP dirs).

Implementations

impl MaterializeConfig

pub fn effective_mode(&self) -> MaterializeMode

Resolve write mode: env RBT_MATERIALIZE_MODE=stream|collect overrides yml.

pub fn choose_ref_backend(&self, row_count: usize) -> RefBackend

Decide MemTable vs lake file for a model that produced row_count rows.

Trait Implementations

impl Clone for MaterializeConfig

fn clone(&self) -> MaterializeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MaterializeConfig

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

Formats the value using the given formatter.

impl Default for MaterializeConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MaterializeConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for MaterializeConfig

impl PartialEq for MaterializeConfig

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for MaterializeConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MaterializeConfig