Function materialize_stream 

pub async fn materialize_stream(
    stream: SendableRecordBatchStream,
    format: &OutputFormat,
    destination_path: &Path,
    opts: &MaterializeWriteOptions,
    assertions: &[Assertion],
) -> Result<StreamWriteStats>

Stream a DataFusion result into destination_path for the given format.

On any error, partial artifacts are deleted (previous successful dest is left intact until a successful atomic replace).