Function encode_write

core/mutable_batch_pb/src/encode.rs:16–25

Convert a [`DmlWrite`] to a [`DatabaseBatch`]

(database_id: i64, write: &DmlWrite)

/// Convert a [`DmlWrite`] to a [`DatabaseBatch`]
pub fn encode_write(database_id: i64, write: &DmlWrite) -> DatabaseBatch {
    DatabaseBatch {
        table_batches: write
            .tables()
            .map(|(table_id, batch)| encode_batch(table_id.get(), batch))
            .collect(),
        partition_key: write.partition_key().to_string(),
        database_id,
    }
}

/// Encode the given mutable batch to a [`TableBatchWithoutId`]. Basically same as [`encode_batch`],
/// but when you don't have an id.