bulk_import add apiKey note

Signed-off-by: lentitude2tk <xushuang.hu@zilliz.com>

Author: lentitude2tk

examples/src/main/java/io/milvus/v1/BulkWriterExample.java

@@ -499,6 +499,7 @@ private void callBulkInsert(CollectionSchemaParam collectionSchema, List<List<St
                 .collectionName(ALL_TYPES_COLLECTION_NAME)
                 .partitionName("")
                 .files(batchFiles)
+                .apiKey(USER_NAME + ":" + PASSWORD)
                 .build();
         String bulkImportResult = BulkImportUtils.bulkImport(url, milvusImportRequest);
         System.out.println(bulkImportResult);
@@ -508,7 +509,9 @@ private void callBulkInsert(CollectionSchemaParam collectionSchema, List<List<St
         System.out.println("Create a bulkInert task, job id: " + jobId);
 
         System.out.println("\n===================== listBulkInsertJobs() ====================");
-        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME).build();
+        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME)
+                .apiKey(USER_NAME + ":" + PASSWORD)
+                .build();
         String listImportJobsResult = BulkImportUtils.listImportJobs(url, listImportJobsRequest);
         System.out.println(listImportJobsResult);
         while (true) {
@@ -518,6 +521,7 @@ private void callBulkInsert(CollectionSchemaParam collectionSchema, List<List<St
             System.out.println("\n===================== getBulkInsertState() ====================");
             MilvusDescribeImportRequest request = MilvusDescribeImportRequest.builder()
                     .jobId(jobId)
+                    .apiKey(USER_NAME + ":" + PASSWORD)
                     .build();
             String getImportProgressResult = BulkImportUtils.getImportProgress(url, request);
             System.out.println(getImportProgressResult);

examples/src/main/java/io/milvus/v2/bulkwriter/BulkWriterRemoteExample.java

@@ -442,6 +442,7 @@ private static void callBulkInsert(List<List<String>> batchFiles) throws Interru
         MilvusImportRequest milvusImportRequest = MilvusImportRequest.builder()
                 .collectionName(ALL_TYPES_COLLECTION_NAME)
                 .files(batchFiles)
+                .apiKey(USER_NAME + ":" + PASSWORD)
                 .options(options)
                 .build();
         String bulkImportResult = BulkImportUtils.bulkImport(url, milvusImportRequest);
@@ -452,7 +453,9 @@ private static void callBulkInsert(List<List<String>> batchFiles) throws Interru
         System.out.println("Create a bulkInert task, job id: " + jobId);
 
         System.out.println("\n===================== listBulkInsertJobs() ====================");
-        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME).build();
+        MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME)
+                .apiKey(USER_NAME + ":" + PASSWORD)
+                .build();
         String listImportJobsResult = BulkImportUtils.listImportJobs(url, listImportJobsRequest);
         System.out.println(listImportJobsResult);
         while (true) {
@@ -462,6 +465,7 @@ private static void callBulkInsert(List<List<String>> batchFiles) throws Interru
             System.out.println("\n===================== getBulkInsertState() ====================");
             MilvusDescribeImportRequest request = MilvusDescribeImportRequest.builder()
                     .jobId(jobId)
+                    .apiKey(USER_NAME + ":" + PASSWORD)
                     .build();
             String getImportProgressResult = BulkImportUtils.getImportProgress(url, request);
             System.out.println(getImportProgressResult);

sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java

@@ -33,7 +33,8 @@
 public class BaseDescribeImportRequest implements Serializable {
     private static final long serialVersionUID = -787626534606813089L;
     /**
-     * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it.
+     * If you are calling the cloud API, this parameter should be set to your API_KEY.
+     * If you are using Milvus directly, this parameter should be set to your userName:password.
      */
     private String apiKey;
 }

sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/import_/BaseImportRequest.java

@@ -34,7 +34,8 @@
 public class BaseImportRequest implements Serializable {
     private static final long serialVersionUID = 8192049841043084620L;
     /**
-     * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it.
+     * If you are calling the cloud API, this parameter should be set to your API_KEY.
+     * If you are using Milvus directly, this parameter should be set to your userName:password.
      */
     private String apiKey;
 

sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/list/BaseListImportJobsRequest.java

@@ -34,7 +34,8 @@
 public class BaseListImportJobsRequest implements Serializable {
     private static final long serialVersionUID = -1890380396466908530L;
     /**
-     * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it.
+     * If you are calling the cloud API, this parameter should be set to your API_KEY.
+     * If you are using Milvus directly, this parameter should be set to your userName:password.
      */
     private String apiKey;
 }