Use server-side batching in the quickstart import step

_includes/code/csharp/QuickstartLocalTest.cs

@@ -87,21 +87,25 @@ public async Task FullQuickstartWorkflowTest()
             );
         }
 
-        // Call InsertMany with the list of objects converted to an array
-        var insertResponse = await questions.Data.InsertMany(questionsToInsert.ToArray());
+        // `Batch.InsertMany` imports the list using server-side batching
+        var insertResponse = await questions.Batch.InsertMany(questionsToInsert);
         // highlight-end
-        // END Import
 
         // Check for errors
         if (insertResponse.HasErrors)
         {
             Console.WriteLine($"Number of failed imports: {insertResponse.Errors.Count()}");
-            Console.WriteLine($"First failed object error: {insertResponse.Errors.First()}");
+            // `Objects` holds one entry per object; `Index` is the position of the object in the input
+            foreach (var entry in insertResponse.Objects.Where(o => o.Error is not null))
+            {
+                Console.WriteLine($"Failed object at index {entry.Index}: {entry.Error.Message}");
+            }
         }
         else
         {
-            Console.WriteLine($"Successfully inserted {insertResponse.Objects.Count()} objects.");
+            Console.WriteLine($"Successfully inserted {insertResponse.Count} objects.");
         }
+        // END Import
 
         // START NearText
         // highlight-start

_includes/code/csharp/QuickstartTest.cs

@@ -95,21 +95,25 @@ public static async Task FullQuickstartWorkflowTest()
             );
         }
 
-        // Call InsertMany with the list of objects converted to an array
-        var insertResponse = await questions.Data.InsertMany(questionsToInsert.ToArray());
+        // `Batch.InsertMany` imports the list using server-side batching
+        var insertResponse = await questions.Batch.InsertMany(questionsToInsert);
         // highlight-end
-        // END Import
 
         // Check for errors
         if (insertResponse.HasErrors)
         {
             Console.WriteLine($"Number of failed imports: {insertResponse.Errors.Count()}");
-            Console.WriteLine($"First failed object error: {insertResponse.Errors.First()}");
+            // `Objects` holds one entry per object; `Index` is the position of the object in the input
+            foreach (var entry in insertResponse.Objects.Where(o => o.Error is not null))
+            {
+                Console.WriteLine($"Failed object at index {entry.Index}: {entry.Error.Message}");
+            }
         }
         else
         {
-            Console.WriteLine($"Successfully inserted {insertResponse.Objects.Count()} objects.");
+            Console.WriteLine($"Successfully inserted {insertResponse.Count} objects.");
         }
+        // END Import
 
         // START NearText
         // highlight-start

_includes/code/csharp/quickstart/QuickstartCreate.cs

@@ -65,8 +65,8 @@ public static async Task Run()
                 },
             };
 
-            // Insert objects using InsertMany
-            var insertResponse = await movies.Data.InsertMany(dataObjects.ToArray());
+            // Insert the objects using server-side batching
+            var insertResponse = await movies.Batch.InsertMany(dataObjects);
 
             if (insertResponse.HasErrors)
             {

_includes/code/csharp/quickstart/QuickstartCreateVectors.cs

@@ -92,8 +92,8 @@ public static async Task Run()
                 ),
             };
 
-            // Insert the objects with vectors
-            var insertResponse = await movies.Data.InsertMany(dataToInsert);
+            // Insert the objects with vectors using server-side batching
+            var insertResponse = await movies.Batch.InsertMany(dataToInsert);
 
             if (insertResponse.HasErrors)
             {

_includes/code/csharp/quickstart/QuickstartLocalCreate.cs

@@ -70,8 +70,8 @@ public static async Task Run()
                 },
             };
 
-            // Insert objects using InsertMany
-            var insertResponse = await movies.Data.InsertMany(dataObjects.ToArray());
+            // Insert the objects using server-side batching
+            var insertResponse = await movies.Batch.InsertMany(dataObjects);
 
             if (insertResponse.HasErrors)
             {

_includes/code/csharp/quickstart/QuickstartLocalCreateVectors.cs

@@ -76,8 +76,8 @@ public static async Task Run()
                 ),
             };
 
-            // Insert the objects with vectors
-            var insertResponse = await movies.Data.InsertMany(dataToInsert);
+            // Insert the objects with vectors using server-side batching
+            var insertResponse = await movies.Batch.InsertMany(dataToInsert);
             if (insertResponse.HasErrors)
             {
                 Console.WriteLine($"Errors during import: {insertResponse.Errors}");

_includes/code/java-v6/src/test/java/QuickstartLocalTest.java

@@ -3,7 +3,8 @@
 import io.weaviate.client6.v1.api.collections.Generative;
 import io.weaviate.client6.v1.api.collections.Property;
 import io.weaviate.client6.v1.api.collections.VectorConfig;
-import io.weaviate.client6.v1.api.collections.data.InsertManyResponse;
+import io.weaviate.client6.v1.api.collections.WeaviateObject;
+import io.weaviate.client6.v1.api.collections.batch.BatchContext;
 
 import org.json.JSONArray;
 import org.json.JSONObject;
@@ -94,16 +95,21 @@ void testImportDataWorkflow() throws Exception {
       questionsToInsert.add(properties);
     });
 
-    // Call insertMany with the list of objects
-    InsertManyResponse insertResponse = questions.data.insertMany(questionsToInsert.toArray(new Map[0]));
+    // `batch.start()` opens a server-side batch
+    BatchContext<Map<String, Object>> batch = questions.batch.start();
+    // Closing the batch sends the remaining objects and waits for the results
+    try (batch) {
+      for (Map<String, Object> properties : questionsToInsert) {
+        batch.add(WeaviateObject.<Map<String, Object>>of(o -> o.properties(properties)));
+      }
+    }
     // highlight-end
 
     // Check for errors
-    if (!insertResponse.errors().isEmpty()) {
-      System.err.printf("Number of failed imports: %d\n", insertResponse.errors().size());
-      System.err.printf("First failed object error: %s\n", insertResponse.errors().get(0));
+    if (batch.numberOfErrors() > 0) {
+      System.err.printf("Number of failed imports: %d\n", batch.numberOfErrors());
     } else {
-      System.out.printf("Successfully inserted %d objects.\n", insertResponse.uuids().size());
+      System.out.printf("Successfully inserted %d objects.\n", questionsToInsert.size());
     }
     // END Import
     // client.collections.delete(collectionName);

_includes/code/java-v6/src/test/java/QuickstartTest.java

@@ -3,7 +3,8 @@
 import io.weaviate.client6.v1.api.collections.Generative;
 import io.weaviate.client6.v1.api.collections.Property;
 import io.weaviate.client6.v1.api.collections.VectorConfig;
-import io.weaviate.client6.v1.api.collections.data.InsertManyResponse;
+import io.weaviate.client6.v1.api.collections.WeaviateObject;
+import io.weaviate.client6.v1.api.collections.batch.BatchContext;
 
 import org.json.JSONArray;
 import org.json.JSONObject;
@@ -115,16 +116,21 @@ void testImportDataWorkflow() throws Exception {
       questionsToInsert.add(properties);
     });
 
-    // Call insertMany with the list of objects
-    InsertManyResponse insertResponse = questions.data.insertMany(questionsToInsert.toArray(new Map[0]));
+    // `batch.start()` opens a server-side batch
+    BatchContext<Map<String, Object>> batch = questions.batch.start();
+    // Closing the batch sends the remaining objects and waits for the results
+    try (batch) {
+      for (Map<String, Object> properties : questionsToInsert) {
+        batch.add(WeaviateObject.<Map<String, Object>>of(o -> o.properties(properties)));
+      }
+    }
     // highlight-end
 
     // Check for errors
-    if (!insertResponse.errors().isEmpty()) {
-      System.err.printf("Number of failed imports: %d\n", insertResponse.errors().size());
-      System.err.printf("First failed object error: %s\n", insertResponse.errors().get(0));
+    if (batch.numberOfErrors() > 0) {
+      System.err.printf("Number of failed imports: %d\n", batch.numberOfErrors());
     } else {
-      System.out.printf("Successfully inserted %d objects.\n", insertResponse.uuids().size());
+      System.out.printf("Successfully inserted %d objects.\n", questionsToInsert.size());
     }
     // END Import
     // client.collections.delete(collectionName);

_includes/code/java-v6/src/test/java/quickstart/QuickstartCreate.java

@@ -5,7 +5,8 @@
 import io.weaviate.client6.v1.api.collections.CollectionHandle;
 import io.weaviate.client6.v1.api.collections.Property;
 import io.weaviate.client6.v1.api.collections.VectorConfig;
-import io.weaviate.client6.v1.api.collections.data.InsertManyResponse;
+import io.weaviate.client6.v1.api.collections.WeaviateObject;
+import io.weaviate.client6.v1.api.collections.batch.BatchContext;
 
 import java.util.List;
 import java.util.Map;
@@ -54,18 +55,24 @@ public static void main(String[] args) throws Exception {
               "A meek Hobbit and his companions set out on a perilous journey to destroy a powerful ring and save Middle-earth.",
               "genre", "Fantasy"));
 
-      // Insert objects using insertMany
+      // Insert the objects using server-side batching
       CollectionHandle<Map<String, Object>> movies =
           client.collections.use(collectionName);
-      InsertManyResponse insertResponse =
-          movies.data.insertMany(dataObjects.toArray(new Map[0]));
+      BatchContext<Map<String, Object>> batch = movies.batch.start();
+      // Closing the batch sends the remaining objects and waits for the results
+      try (batch) {
+        for (Map<String, Object> properties : dataObjects) {
+          batch.add(
+              WeaviateObject.<Map<String, Object>>of(o -> o.properties(properties)));
+        }
+      }
 
-      if (!insertResponse.errors().isEmpty()) {
-        System.err.println("Errors during import: " + insertResponse.errors());
+      if (batch.numberOfErrors() > 0) {
+        System.err
+            .println("Number of failed imports: " + batch.numberOfErrors());
       } else {
-        System.out
-            .println("Imported & vectorized " + insertResponse.uuids().size()
-                + " objects into the Movie collection");
+        System.out.println("Imported & vectorized " + dataObjects.size()
+            + " objects into the Movie collection");
       }
     } finally {
       if (client != null) {

_includes/code/java-v6/src/test/java/quickstart/QuickstartCreateVectors.java

@@ -7,7 +7,8 @@
 import io.weaviate.client6.v1.api.collections.VectorConfig;
 import io.weaviate.client6.v1.api.collections.Vectors;
 import io.weaviate.client6.v1.api.collections.WeaviateObject;
-import io.weaviate.client6.v1.api.collections.data.InsertManyResponse;
+import io.weaviate.client6.v1.api.collections.batch.BatchContext;
+import java.util.List;
 import java.util.Map;
 
 public class QuickstartCreateVectors {
@@ -63,20 +64,30 @@ public static void main(String[] args) throws Exception {
       float[] vector3 =
           new float[] {0.3f, 0.4f, 0.5f, 0.6f, 0.7f, 0.8f, 0.9f, 1.0f};
 
-      // Insert the objects with vectors
+      // Insert the objects with vectors using server-side batching
       CollectionHandle<Map<String, Object>> movies =
           client.collections.use(collectionName);
-      InsertManyResponse insertResponse = movies.data.insertMany(
+      List<WeaviateObject<Map<String, Object>>> objectsToInsert = List.of(
           WeaviateObject.of(v -> v.properties(props1)
               .vectors(Vectors.of(vector1))),
           WeaviateObject.of(v -> v.properties(props2)
               .vectors(Vectors.of(vector2))),
           WeaviateObject.of(v -> v.properties(props3)
               .vectors(Vectors.of(vector3))));
-      if (!insertResponse.errors().isEmpty()) {
-        System.err.println("Errors during import: " + insertResponse.errors());
+
+      BatchContext<Map<String, Object>> batch = movies.batch.start();
+      // Closing the batch sends the remaining objects and waits for the results
+      try (batch) {
+        for (WeaviateObject<Map<String, Object>> object : objectsToInsert) {
+          batch.add(object);
+        }
+      }
+
+      if (batch.numberOfErrors() > 0) {
+        System.err
+            .println("Number of failed imports: " + batch.numberOfErrors());
       } else {
-        System.out.println("Imported " + insertResponse.uuids().size()
+        System.out.println("Imported " + objectsToInsert.size()
             + " objects with vectors into the Movie collection");
       }
     } finally {

_includes/code/java-v6/src/test/java/quickstart/QuickstartLocalCreate.java

@@ -5,7 +5,8 @@
 import io.weaviate.client6.v1.api.collections.CollectionHandle;
 import io.weaviate.client6.v1.api.collections.Property;
 import io.weaviate.client6.v1.api.collections.VectorConfig;
-import io.weaviate.client6.v1.api.collections.data.InsertManyResponse;
+import io.weaviate.client6.v1.api.collections.WeaviateObject;
+import io.weaviate.client6.v1.api.collections.batch.BatchContext;
 
 import java.util.List;
 import java.util.Map;
@@ -53,18 +54,24 @@ public static void main(String[] args) throws Exception {
               "A meek Hobbit and his companions set out on a perilous journey to destroy a powerful ring and save Middle-earth.",
               "genre", "Fantasy"));
 
-      // Insert objects using insertMany
+      // Insert the objects using server-side batching
       CollectionHandle<Map<String, Object>> movies =
           client.collections.use(collectionName);
-      InsertManyResponse insertResponse =
-          movies.data.insertMany(dataObjects.toArray(new Map[0]));
+      BatchContext<Map<String, Object>> batch = movies.batch.start();
+      // Closing the batch sends the remaining objects and waits for the results
+      try (batch) {
+        for (Map<String, Object> properties : dataObjects) {
+          batch.add(
+              WeaviateObject.<Map<String, Object>>of(o -> o.properties(properties)));
+        }
+      }
 
-      if (!insertResponse.errors().isEmpty()) {
-        System.err.println("Errors during import: " + insertResponse.errors());
+      if (batch.numberOfErrors() > 0) {
+        System.err
+            .println("Number of failed imports: " + batch.numberOfErrors());
       } else {
-        System.out
-            .println("Imported & vectorized " + insertResponse.uuids().size()
-                + " objects into the Movie collection");
+        System.out.println("Imported & vectorized " + dataObjects.size()
+            + " objects into the Movie collection");
       }
     } finally {
       if (client != null) {

_includes/code/java-v6/src/test/java/quickstart/QuickstartLocalCreateVectors.java

@@ -7,7 +7,8 @@
 import io.weaviate.client6.v1.api.collections.VectorConfig;
 import io.weaviate.client6.v1.api.collections.Vectors;
 import io.weaviate.client6.v1.api.collections.WeaviateObject;
-import io.weaviate.client6.v1.api.collections.data.InsertManyResponse;
+import io.weaviate.client6.v1.api.collections.batch.BatchContext;
+import java.util.List;
 import java.util.Map;
 
 public class QuickstartLocalCreateVectors {
@@ -59,21 +60,30 @@ public static void main(String[] args) throws Exception {
       float[] vector3 =
           new float[] {0.3f, 0.4f, 0.5f, 0.6f, 0.7f, 0.8f, 0.9f, 1.0f};
 
-      // Insert the objects with vectors
+      // Insert the objects with vectors using server-side batching
       CollectionHandle<Map<String, Object>> movies =
           client.collections.use(collectionName);
-      InsertManyResponse insertResponse = movies.data.insertMany(
+      List<WeaviateObject<Map<String, Object>>> objectsToInsert = List.of(
           WeaviateObject.of(v -> v.properties(props1)
               .vectors(Vectors.of(vector1))),
           WeaviateObject.of(v -> v.properties(props2)
               .vectors(Vectors.of(vector2))),
           WeaviateObject.of(v -> v.properties(props3)
               .vectors(Vectors.of(vector3))));
 
-      if (!insertResponse.errors().isEmpty()) {
-        System.err.println("Errors during import: " + insertResponse.errors());
+      BatchContext<Map<String, Object>> batch = movies.batch.start();
+      // Closing the batch sends the remaining objects and waits for the results
+      try (batch) {
+        for (WeaviateObject<Map<String, Object>> object : objectsToInsert) {
+          batch.add(object);
+        }
+      }
+
+      if (batch.numberOfErrors() > 0) {
+        System.err
+            .println("Number of failed imports: " + batch.numberOfErrors());
       } else {
-        System.out.println("Imported " + insertResponse.uuids().size()
+        System.out.println("Imported " + objectsToInsert.size()
             + " objects with vectors into the Movie collection");
       }
     } finally {

_includes/code/llms-txt/python/quickstart.py

@@ -46,9 +46,7 @@
     movies = client.collections.use("Movie__QuickstartPy")
 
     # Import objects
-    with movies.batch.fixed_size(batch_size=200) as batch:
-        for obj in data_objects:
-            batch.add_object(properties=obj)
+    movies.data.ingest(data_objects)
 
     print(f"Imported & vectorized {len(data_objects)} objects into the Movie collection")
 

_includes/code/llms-txt/typescript/quickstart.ts

@@ -36,7 +36,7 @@ if (!(await client.collections.exists('Movie__QuickstartTs'))) {
 const movies = client.collections.use('Movie__QuickstartTs');
 
 // Import objects
-await movies.data.insertMany(dataObjects);
+await movies.data.ingest(dataObjects.map((properties) => ({ properties })));
 
 console.log(`Imported & vectorized ${dataObjects.length} objects into the Movie collection`);