@@ -354,9 +354,9 @@ func (c *Client) sendBulkUpsertRequest(
354354 return nil
355355}
356356
357- // chunkBulkUpsertRequest splits a BulkUpsertRequest into smaller chunks if it exceeds the maximum message size.
358- // It recursively divides the request's rows into smaller requests while preserving the original request structure .
359- // If the request is smaller than the maximum size or contains fewer than two rows, it returns the original request .
357+ // chunkBulkUpsertRequest splits a bulk upsert request into smaller chunks if it exceeds the maximum message size.
358+ // It recursively divides the request into smaller parts, ensuring each chunk is within the size limit .
359+ // Returns a slice of chunked bulk upsert requests or an error if the request cannot be split .
360360func chunkBulkUpsertRequest (
361361 dst []* Ydb_Table.BulkUpsertRequest ,
362362 req * Ydb_Table.BulkUpsertRequest ,
@@ -400,10 +400,10 @@ func chunkBulkUpsertRequest(
400400 return chunkBulkUpsertRequest (dst , right , maxBytes )
401401}
402402
403- // splitBulkUpsertRequestAt splits a BulkUpsertRequest into two parts at the specified position.
404- // It creates a new request with items from the specified position to the end,
405- // while modifying the original request to contain only items before the position .
406- // Returns the newly created request with the split items .
403+ // splitBulkUpsertRequestAt splits a bulk upsert request into two parts at the specified position.
404+ // It divides the request's items into two separate requests, with the first request containing
405+ // items from the start up to the specified position, and the second request containing the remaining items .
406+ // Returns two modified bulk upsert requests with their respective item sets .
407407func splitBulkUpsertRequestAt (req * Ydb_Table.BulkUpsertRequest , pos int ) (_ , _ * Ydb_Table.BulkUpsertRequest ) {
408408 items := req .GetRows ().GetValue ().GetItems () // save original items
409409 req .Rows .Value .Items = nil
0 commit comments