Breaking change: Rename Stage to Volume

Author: lentitude2tk

sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/VolumeFileManager.java

@@ -149,11 +149,27 @@ public void shutdownGracefully() {
     }
 
     private void initValidator(Pair<List<String>, Long> localPathPair) {
-        if (localPathPair.getValue() > applyVolumeResponse.getCondition().getMaxContentLength()) {
-            String msg = String.format("localFileTotalSize %s exceeds the maximum contentLength limit %s defined in the condition. If you want to upload larger files, please contact us to lift the restriction", localPathPair.getValue(), applyVolumeResponse.getCondition().getMaxContentLength());
+        Long maxContentLength = applyVolumeResponse.getCondition().getMaxContentLength();
+        Long uploadFileContentLength = localPathPair.getValue();
+        if (uploadFileContentLength > maxContentLength) {
+            String msg = String.format("localFileTotalSize %s exceeds the maximum contentLength limit %s defined in the condition. If you are using the free tier, you may switch to the pay-as-you-go volume plan to support uploading larger files.",
+                    uploadFileContentLength, maxContentLength);
             logger.error(msg);
             throw new ParamException(msg);
         }
+
+        Long maxFileNumber = applyVolumeResponse.getCondition().getMaxFileNumber();
+        int uploadFileNumber = localPathPair.getKey().size();
+        if (maxFileNumber != null) {
+            if (uploadFileNumber > maxFileNumber) {
+                String msg = String.format(
+                        "localFileTotalNumber %s exceeds the maximum fileNumber limit %s defined in the condition. If you are using the free tier, you may switch to the pay-as-you-go volume plan to support uploading more files.",
+                        uploadFileNumber, maxFileNumber
+                );
+                logger.error(msg);
+                throw new ParamException(msg);
+            }
+        }
     }
 
     private void refreshVolumeAndClient(String path) {

sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/response/ApplyVolumeResponse.java

@@ -316,6 +316,7 @@ public Credentials build() {
     public static class Condition implements Serializable {
         private static final long serialVersionUID = -2613029991242322109L;
         private Long maxContentLength;
+        private Long maxFileNumber;
 
         public Condition() {
         }
@@ -332,6 +333,10 @@ public Long getMaxContentLength() {
             return maxContentLength;
         }
 
+        public Long getMaxFileNumber() {
+            return maxFileNumber;
+        }
+
         public void setMaxContentLength(Long maxContentLength) {
             this.maxContentLength = maxContentLength;
         }
@@ -340,6 +345,7 @@ public void setMaxContentLength(Long maxContentLength) {
         public String toString() {
             return "Condition{" +
                     ", maxContentLength=" + maxContentLength +
+                    ", maxFileNumber=" + maxFileNumber +
                     '}';
         }