Struct WapMaterializer 

pub struct WapMaterializer {
    pub target_table: String,
    pub wap_branch: String,
    pub staging_dir: PathBuf,
}

Write-Audit-Publish (WAP) Materializer — audit helpers (catalog branch publish later).

Fields

target_table: String

wap_branch: String

staging_dir: PathBuf

Implementations

impl WapMaterializer

pub fn new( target_table: impl Into<String>, wap_branch: impl Into<String>, staging_dir: impl AsRef<Path>, ) -> Self

pub async fn write_stage(&self, batches: &[RecordBatch]) -> Result<usize>

pub fn audit_stage( &self, batches: &[RecordBatch], assertions: &[Assertion], ) -> Result<ValidationResult>

pub async fn publish_stage( &self, audit_result: &ValidationResult, ) -> Result<WapStatus>