bulkWriter interface.
*/
-@Getter
-@ToString
public class LocalBulkWriterParam {
private final CreateCollectionReq.CollectionSchema collectionSchema;
private final String localPath;
@@ -44,7 +39,7 @@ public class LocalBulkWriterParam {
private final BulkFileType fileType;
private final MapBuilder
*/
- public Builder withCollectionSchema(@NonNull CollectionSchemaParam collectionSchema) {
+ public Builder withCollectionSchema(CollectionSchemaParam collectionSchema) {
this.collectionSchema = V2AdapterUtils.convertV1Schema(collectionSchema);
return this;
}
@@ -86,7 +111,7 @@ public Builder withCollectionSchema(@NonNull CollectionSchemaParam collectionSch
* @param collectionSchema collection schema
* @return Builder
*/
- public Builder withCollectionSchema(@NonNull CreateCollectionReq.CollectionSchema collectionSchema) {
+ public Builder withCollectionSchema(CreateCollectionReq.CollectionSchema collectionSchema) {
this.collectionSchema = collectionSchema;
return this;
}
@@ -97,7 +122,7 @@ public Builder withCollectionSchema(@NonNull CreateCollectionReq.CollectionSchem
* @param localPath collection name
* @return Builder
*/
- public Builder withLocalPath(@NonNull String localPath) {
+ public Builder withLocalPath(String localPath) {
this.localPath = localPath;
return this;
}
@@ -132,5 +157,4 @@ public LocalBulkWriterParam build() throws ParamException {
return new LocalBulkWriterParam(this);
}
}
-
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/RemoteBulkWriter.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/RemoteBulkWriter.java
index 98a418037..2564287ca 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/RemoteBulkWriter.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/RemoteBulkWriter.java
@@ -47,11 +47,11 @@
public class RemoteBulkWriter extends LocalBulkWriter {
private static final Logger logger = LoggerFactory.getLogger(RemoteBulkWriter.class);
- private String remotePath;
- private StorageConnectParam connectParam;
+ private final String remotePath;
+ private final StorageConnectParam connectParam;
private StorageClient storageClient;
- private ListbulkWriter interface.
*/
-@Getter
-@ToString
public class RemoteBulkWriterParam {
private final CreateCollectionReq.CollectionSchema collectionSchema;
private final StorageConnectParam connectParam;
@@ -47,7 +41,7 @@ public class RemoteBulkWriterParam {
private final BulkFileType fileType;
private final MapBuilder
*/
- public Builder withCollectionSchema(@NonNull CollectionSchemaParam collectionSchema) {
+ public Builder withCollectionSchema(CollectionSchemaParam collectionSchema) {
this.collectionSchema = V2AdapterUtils.convertV1Schema(collectionSchema);
return this;
}
@@ -91,12 +119,12 @@ public Builder withCollectionSchema(@NonNull CollectionSchemaParam collectionSch
* @param collectionSchema collection schema
* @return Builder
*/
- public Builder withCollectionSchema(@NonNull CreateCollectionReq.CollectionSchema collectionSchema) {
+ public Builder withCollectionSchema(CreateCollectionReq.CollectionSchema collectionSchema) {
this.collectionSchema = collectionSchema;
return this;
}
- public Builder withConnectParam(@NotNull StorageConnectParam connectParam) {
+ public Builder withConnectParam(StorageConnectParam connectParam) {
this.connectParam = connectParam;
return this;
}
@@ -107,7 +135,7 @@ public Builder withConnectParam(@NotNull StorageConnectParam connectParam) {
* @param remotePath remote path
* @return Builder
*/
- public Builder withRemotePath(@NonNull String remotePath) {
+ public Builder withRemotePath(String remotePath) {
this.remotePath = remotePath;
return this;
}
@@ -117,7 +145,7 @@ public Builder withChunkSize(long chunkSize) {
return this;
}
- public Builder withFileType(@NonNull BulkFileType fileType) {
+ public Builder withFileType(BulkFileType fileType) {
this.fileType = fileType;
return this;
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageBulkWriter.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageBulkWriter.java
index 3917bdceb..ff4ee56d2 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageBulkWriter.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageBulkWriter.java
@@ -39,10 +39,10 @@
public class StageBulkWriter extends LocalBulkWriter {
private static final Logger logger = LoggerFactory.getLogger(StageBulkWriter.class);
- private String remotePath;
- private ListstageBulkWriter interface.
*/
-@Getter
-@ToString
public class StageBulkWriterParam {
private final CreateCollectionReq.CollectionSchema collectionSchema;
private final String remotePath;
@@ -49,7 +43,7 @@ public class StageBulkWriterParam {
private final String apiKey;
private final String stageName;
- private StageBulkWriterParam(@NonNull Builder builder) {
+ private StageBulkWriterParam(Builder builder) {
this.collectionSchema = builder.collectionSchema;
this.remotePath = builder.remotePath;
this.chunkSize = builder.chunkSize;
@@ -61,6 +55,50 @@ private StageBulkWriterParam(@NonNull Builder builder) {
this.stageName = builder.stageName;
}
+ public CreateCollectionReq.CollectionSchema getCollectionSchema() {
+ return collectionSchema;
+ }
+
+ public String getRemotePath() {
+ return remotePath;
+ }
+
+ public long getChunkSize() {
+ return chunkSize;
+ }
+
+ public BulkFileType getFileType() {
+ return fileType;
+ }
+
+ public MapBuilder
*/
- public Builder withCollectionSchema(@NonNull CollectionSchemaParam collectionSchema) {
+ public Builder withCollectionSchema(CollectionSchemaParam collectionSchema) {
this.collectionSchema = V2AdapterUtils.convertV1Schema(collectionSchema);
return this;
}
@@ -100,7 +138,7 @@ public Builder withCollectionSchema(@NonNull CollectionSchemaParam collectionSch
* @param collectionSchema collection schema
* @return Builder
*/
- public Builder withCollectionSchema(@NonNull CreateCollectionReq.CollectionSchema collectionSchema) {
+ public Builder withCollectionSchema(CreateCollectionReq.CollectionSchema collectionSchema) {
this.collectionSchema = collectionSchema;
return this;
}
@@ -111,7 +149,7 @@ public Builder withCollectionSchema(@NonNull CreateCollectionReq.CollectionSchem
* @param remotePath remote path
* @return Builder
*/
- public Builder withRemotePath(@NonNull String remotePath) {
+ public Builder withRemotePath(String remotePath) {
this.remotePath = remotePath;
return this;
}
@@ -121,7 +159,7 @@ public Builder withChunkSize(long chunkSize) {
return this;
}
- public Builder withFileType(@NonNull BulkFileType fileType) {
+ public Builder withFileType(BulkFileType fileType) {
this.fileType = fileType;
return this;
}
@@ -131,17 +169,17 @@ public Builder withConfig(String key, Object val) {
return this;
}
- public Builder withCloudEndpoint(@NotNull String cloudEndpoint) {
+ public Builder withCloudEndpoint(String cloudEndpoint) {
this.cloudEndpoint = cloudEndpoint;
return this;
}
- public Builder withApiKey(@NotNull String apiKey) {
+ public Builder withApiKey(String apiKey) {
this.apiKey = apiKey;
return this;
}
- public Builder withStageName(@NotNull String stageName) {
+ public Builder withStageName(String stageName) {
this.stageName = stageName;
return this;
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManager.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManager.java
index 4311e7fce..9aec466a9 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManager.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManager.java
@@ -42,12 +42,7 @@
import java.time.Instant;
import java.util.Date;
import java.util.List;
-import java.util.concurrent.Callable;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CompletionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
@@ -131,12 +126,12 @@ public CompletableFuture* Usage recommendation: *
* Thread interruption is respected, and the interrupt status is restored if interrupted during shutdown.
*/
public void shutdownGracefully() {
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManagerParam.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManagerParam.java
index 8cb0b623e..c64b4873d 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManagerParam.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageFileManagerParam.java
@@ -22,29 +22,48 @@
import io.milvus.bulkwriter.common.clientenum.ConnectType;
import io.milvus.exception.ParamException;
import io.milvus.param.ParamUtils;
-import lombok.Getter;
-import lombok.NonNull;
-import lombok.ToString;
-import org.jetbrains.annotations.NotNull;
/**
* Parameters for
* 1. Multi-path import (multiple folders or files):
- * "objectUrls": [
- * ["s3://bucket-name/parquet-folder-1/1.parquet"],
- * ["s3://bucket-name/parquet-folder-2/1.parquet"],
- * ["s3://bucket-name/parquet-folder-3/"]
- * ]
+ * "objectUrls": [
+ * ["s3://bucket-name/parquet-folder-1/1.parquet"],
+ * ["s3://bucket-name/parquet-folder-2/1.parquet"],
+ * ["s3://bucket-name/parquet-folder-3/"]
+ * ]
*
* 2. Folder import:
- * "objectUrls": [
- * ["s3://bucket-name/parquet-folder/"]
- * ]
+ * "objectUrls": [
+ * ["s3://bucket-name/parquet-folder/"]
+ * ]
*
* 3. Single file import:
- * "objectUrls": [
- * ["s3://bucket-name/parquet-folder/1.parquet"]
- * ]
+ * "objectUrls": [
+ * ["s3://bucket-name/parquet-folder/1.parquet"]
+ * ]
*/
private List
* Folder import:
- * "objectUrl": "s3://bucket-name/parquet-folder/"
+ * "objectUrl": "s3://bucket-name/parquet-folder/"
*
* File import:
- * "objectUrl": "s3://bucket-name/parquet-folder/1.parquet"
+ * "objectUrl": "s3://bucket-name/parquet-folder/1.parquet"
*/
@Deprecated
private String objectUrl;
- /** Specify `accessKey` and `secretKey`; for short-term credentials, also include `token`. */
+ /**
+ * Specify `accessKey` and `secretKey`; for short-term credentials, also include `token`.
+ */
private String accessKey;
- /** Specify `accessKey` and `secretKey`; for short-term credentials, also include `token`. */
+ /**
+ * Specify `accessKey` and `secretKey`; for short-term credentials, also include `token`.
+ */
private String secretKey;
- /** Specify `accessKey` and `secretKey`; for short-term credentials, also include `token`. */
+ /**
+ * Specify `accessKey` and `secretKey`; for short-term credentials, also include `token`.
+ */
private String token;
+
+ public CloudImportRequest() {
+ }
+
+ public CloudImportRequest(String clusterId, String dbName, String collectionName, String partitionName,
+ List
* 1. Multi-path import (multiple files):
- * "files": [
- * ["parquet-folder-1/1.parquet"],
- * ["parquet-folder-2/1.parquet"],
- * ["parquet-folder-3/1.parquet"]
- * ]
+ * "files": [
+ * ["parquet-folder-1/1.parquet"],
+ * ["parquet-folder-2/1.parquet"],
+ * ["parquet-folder-3/1.parquet"]
+ * ]
*
* 2. Single file import:
- * "files": [
- * ["parquet-folder/1.parquet"]
- * ]
+ * "files": [
+ * ["parquet-folder/1.parquet"]
+ * ]
*/
private List
* 1. Multi-path import (multiple folders or files):
- * "dataPaths": [
- * ["parquet-folder-1/1.parquet"],
- * ["parquet-folder-2/1.parquet"],
- * ["parquet-folder-3/"]
- * ]
+ * "dataPaths": [
+ * ["parquet-folder-1/1.parquet"],
+ * ["parquet-folder-2/1.parquet"],
+ * ["parquet-folder-3/"]
+ * ]
*
* 2. Folder import:
- * "dataPaths": [
- * ["parquet-folder/"]
- * ]
+ * "dataPaths": [
+ * ["parquet-folder/"]
+ * ]
*
* 3. Single file import:
- * "dataPaths": [
- * ["parquet-folder/1.parquet"]
- * ]
+ * "dataPaths": [
+ * ["parquet-folder/1.parquet"]
+ * ]
*/
private ListstageFileManager interface.
*/
-@Getter
-@ToString
public class StageFileManagerParam {
private final String cloudEndpoint;
private final String apiKey;
private final String stageName;
private final ConnectType connectType;
- private StageFileManagerParam(@NonNull Builder builder) {
+ private StageFileManagerParam(Builder builder) {
this.cloudEndpoint = builder.cloudEndpoint;
this.apiKey = builder.apiKey;
this.stageName = builder.stageName;
this.connectType = builder.connectType;
}
+ public String getCloudEndpoint() {
+ return cloudEndpoint;
+ }
+
+ public String getApiKey() {
+ return apiKey;
+ }
+
+ public String getStageName() {
+ return stageName;
+ }
+
+ public ConnectType getConnectType() {
+ return connectType;
+ }
+
+ @Override
+ public String toString() {
+ return "StageFileManagerParam{" +
+ "cloudEndpoint='" + cloudEndpoint + '\'' +
+ ", stageName='" + stageName + '\'' +
+ ", connectType=" + connectType +
+ '}';
+ }
+
public static Builder newBuilder() {
return new Builder();
}
@@ -69,17 +88,17 @@ private Builder() {
* For overseas regions, it is: https://api.cloud.zilliz.com
* For regions in China, it is: https://api.cloud.zilliz.com.cn
*/
- public Builder withCloudEndpoint(@NotNull String cloudEndpoint) {
+ public Builder withCloudEndpoint(String cloudEndpoint) {
this.cloudEndpoint = cloudEndpoint;
return this;
}
- public Builder withApiKey(@NotNull String apiKey) {
+ public Builder withApiKey(String apiKey) {
this.apiKey = apiKey;
return this;
}
- public Builder withStageName(@NotNull String stageName) {
+ public Builder withStageName(String stageName) {
this.stageName = stageName;
return this;
}
@@ -90,7 +109,7 @@ public Builder withStageName(@NotNull String stageName) {
* otherwise, the public endpoint will be used.
* You can also force the use of either the internal or public endpoint.
*/
- public Builder withConnectType(@NotNull ConnectType connectType) {
+ public Builder withConnectType(ConnectType connectType) {
this.connectType = connectType;
return this;
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageManagerParam.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageManagerParam.java
index 0145499d7..8dbb8e2f8 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageManagerParam.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/StageManagerParam.java
@@ -21,25 +21,34 @@
import io.milvus.exception.ParamException;
import io.milvus.param.ParamUtils;
-import lombok.Getter;
-import lombok.NonNull;
-import lombok.ToString;
-import org.jetbrains.annotations.NotNull;
/**
* Parameters for stageManager interface.
*/
-@Getter
-@ToString
public class StageManagerParam {
private final String cloudEndpoint;
private final String apiKey;
- private StageManagerParam(@NonNull Builder builder) {
+ private StageManagerParam(Builder builder) {
this.cloudEndpoint = builder.cloudEndpoint;
this.apiKey = builder.apiKey;
}
+ public String getCloudEndpoint() {
+ return cloudEndpoint;
+ }
+
+ public String getApiKey() {
+ return apiKey;
+ }
+
+ @Override
+ public String toString() {
+ return "StageManagerParam{" +
+ "cloudEndpoint='" + cloudEndpoint + '\'' +
+ '}';
+ }
+
public static Builder newBuilder() {
return new Builder();
}
@@ -60,12 +69,12 @@ private Builder() {
* For overseas regions, it is: https://api.cloud.zilliz.com
* For regions in China, it is: https://api.cloud.zilliz.com.cn
*/
- public Builder withCloudEndpoint(@NotNull String cloudEndpoint) {
+ public Builder withCloudEndpoint(String cloudEndpoint) {
this.cloudEndpoint = cloudEndpoint;
return this;
}
- public Builder withApiKey(@NotNull String apiKey) {
+ public Builder withApiKey(String apiKey) {
this.apiKey = apiKey;
return this;
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/BulkFileType.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/BulkFileType.java
index 728fb1871..86ed78cd1 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/BulkFileType.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/BulkFileType.java
@@ -19,20 +19,25 @@
package io.milvus.bulkwriter.common.clientenum;
-import lombok.Getter;
-
-@Getter
public enum BulkFileType {
PARQUET(1, ".parquet"),
JSON(2, ".json"),
CSV(3, ".csv"),
;
- private Integer code;
- private String suffix;
+ private final Integer code;
+ private final String suffix;
BulkFileType(Integer code, String suffix) {
this.code = code;
this.suffix = suffix;
}
+
+ public Integer getCode() {
+ return code;
+ }
+
+ public String getSuffix() {
+ return suffix;
+ }
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/CloudStorage.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/CloudStorage.java
index 2aba4216a..0a896cc5c 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/CloudStorage.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/common/clientenum/CloudStorage.java
@@ -20,35 +20,32 @@
package io.milvus.bulkwriter.common.clientenum;
import io.milvus.exception.ParamException;
-import lombok.Getter;
import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.util.Lists;
import java.util.List;
public enum CloudStorage {
- MINIO("minio","%s", "minioAddress"),
- AWS("aws","s3.amazonaws.com", null),
- GCP("gcp" ,"storage.googleapis.com", null),
+ MINIO("minio", "%s", "minioAddress"),
+ AWS("aws", "s3.amazonaws.com", null),
+ GCP("gcp", "storage.googleapis.com", null),
- AZ("az" ,"%s.blob.core.windows.net", "accountName"),
- AZURE("azure" ,"%s.blob.core.windows.net", "accountName"),
+ AZ("az", "%s.blob.core.windows.net", "accountName"),
+ AZURE("azure", "%s.blob.core.windows.net", "accountName"),
- ALI("ali","oss-%s.aliyuncs.com", "region"),
- ALIYUN("aliyun","oss-%s.aliyuncs.com", "region"),
- ALIBABA("alibaba","oss-%s.aliyuncs.com", "region"),
- ALICLOU("alicloud","oss-%s.aliyuncs.com", "region"),
+ ALI("ali", "oss-%s.aliyuncs.com", "region"),
+ ALIYUN("aliyun", "oss-%s.aliyuncs.com", "region"),
+ ALIBABA("alibaba", "oss-%s.aliyuncs.com", "region"),
+ ALICLOU("alicloud", "oss-%s.aliyuncs.com", "region"),
- TC("tc","cos.%s.myqcloud.com", "region"),
- TENCENT("tencent","cos.%s.myqcloud.com", "region")
- ;
+ TC("tc", "cos.%s.myqcloud.com", "region"),
+ TENCENT("tencent", "cos.%s.myqcloud.com", "region");
- @Getter
- private String cloudName;
+ private final String cloudName;
- private String endpoint;
+ private final String endpoint;
- private String replace;
+ private final String replace;
CloudStorage(String cloudName, String endpoint, String replace) {
this.cloudName = cloudName;
@@ -56,6 +53,10 @@ public enum CloudStorage {
this.replace = replace;
}
+ public String getCloudName() {
+ return cloudName;
+ }
+
public static boolean isAliCloud(String cloudName) {
ListRemoteBulkWriter interface.
*/
-@Getter
-@ToString
public class AzureConnectParam extends StorageConnectParam {
private final String containerName;
private final String connStr;
private final String accountUrl;
private final TokenCredential credential;
- private AzureConnectParam(@NonNull Builder builder) {
+ private AzureConnectParam(Builder builder) {
this.containerName = builder.containerName;
this.connStr = builder.connStr;
this.accountUrl = builder.accountUrl;
this.credential = builder.credential;
}
+ public String getContainerName() {
+ return containerName;
+ }
+
+ public String getConnStr() {
+ return connStr;
+ }
+
+ public String getAccountUrl() {
+ return accountUrl;
+ }
+
+ public TokenCredential getCredential() {
+ return credential;
+ }
+
+ @Override
+ public String toString() {
+ return "AzureConnectParam{" +
+ "containerName='" + containerName + '\'' +
+ ", connStr='" + connStr + '\'' +
+ ", accountUrl='" + accountUrl + '\'' +
+ '}';
+ }
+
public static Builder newBuilder() {
return new Builder();
}
@@ -64,7 +85,7 @@ private Builder() {
* @param containerName The target container name
* @return Builder
*/
- public Builder withContainerName(@NonNull String containerName) {
+ public Builder withContainerName(@NotNull String containerName) {
this.containerName = containerName;
return this;
}
@@ -76,18 +97,18 @@ public Builder withContainerName(@NonNull String containerName) {
* ...
* @return Builder
*/
- public Builder withConnStr(@NonNull String connStr) {
+ public Builder withConnStr(@NotNull String connStr) {
this.connStr = connStr;
return this;
}
/**
* @param accountUrl A string in format like "https://[storage-account].blob.core.windows.net"
- * Read this link for more info:
- * ...
+ * Read this link for more info:
+ * ...
* @return Builder
*/
- public Builder withAccountUrl(@NonNull String accountUrl) {
+ public Builder withAccountUrl(@NotNull String accountUrl) {
this.accountUrl = accountUrl;
return this;
}
@@ -95,10 +116,10 @@ public Builder withAccountUrl(@NonNull String accountUrl) {
/**
*
* @param credential Account access key for the account, read this link for more info:
- * ...
+ * ...
* @return Builder
*/
- public Builder withCredential(@NonNull TokenCredential credential) {
+ public Builder withCredential(@NotNull TokenCredential credential) {
this.credential = credential;
return this;
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/connect/S3ConnectParam.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/connect/S3ConnectParam.java
index e39d84a39..afb764935 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/connect/S3ConnectParam.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/connect/S3ConnectParam.java
@@ -21,17 +21,12 @@
import io.milvus.exception.ParamException;
import io.milvus.param.ParamUtils;
-import lombok.Getter;
-import lombok.NonNull;
-import lombok.ToString;
import okhttp3.OkHttpClient;
import org.jetbrains.annotations.NotNull;
/**
* Parameters for RemoteBulkWriter interface.
*/
-@Getter
-@ToString
public class S3ConnectParam extends StorageConnectParam {
private final String bucketName;
private final String endpoint;
@@ -42,7 +37,7 @@ public class S3ConnectParam extends StorageConnectParam {
private final OkHttpClient httpClient;
private final String cloudName;
- private S3ConnectParam(@NonNull Builder builder) {
+ private S3ConnectParam(@NotNull Builder builder) {
this.bucketName = builder.bucketName;
this.endpoint = builder.endpoint;
this.accessKey = builder.accessKey;
@@ -53,6 +48,51 @@ private S3ConnectParam(@NonNull Builder builder) {
this.cloudName = builder.cloudName;
}
+ public String getBucketName() {
+ return bucketName;
+ }
+
+ public String getEndpoint() {
+ return endpoint;
+ }
+
+ public String getAccessKey() {
+ return accessKey;
+ }
+
+ public String getSecretKey() {
+ return secretKey;
+ }
+
+ public String getSessionToken() {
+ return sessionToken;
+ }
+
+ public String getRegion() {
+ return region;
+ }
+
+ public OkHttpClient getHttpClient() {
+ return httpClient;
+ }
+
+ public String getCloudName() {
+ return cloudName;
+ }
+
+ @Override
+ public String toString() {
+ return "S3ConnectParam{" +
+ "bucketName='" + bucketName + '\'' +
+ ", endpoint='" + endpoint + '\'' +
+ ", accessKey='" + accessKey + '\'' +
+ ", secretKey='" + secretKey + '\'' +
+ ", sessionToken='" + sessionToken + '\'' +
+ ", region='" + region + '\'' +
+ ", cloudName='" + cloudName + '\'' +
+ '}';
+ }
+
public static Builder newBuilder() {
return new Builder();
}
@@ -90,7 +130,7 @@ public Builder withCloudName(@NotNull String cloudName) {
* @param bucketName bucket info
* @return Builder
*/
- public Builder withBucketName(@NonNull String bucketName) {
+ public Builder withBucketName(@NotNull String bucketName) {
this.bucketName = bucketName;
return this;
}
@@ -101,32 +141,32 @@ public Builder withBucketName(@NonNull String bucketName) {
* @param endpoint endpoint info
* @return Builder
*/
- public Builder withEndpoint(@NonNull String endpoint) {
+ public Builder withEndpoint(@NotNull String endpoint) {
this.endpoint = endpoint;
return this;
}
- public Builder withAccessKey(@NonNull String accessKey) {
+ public Builder withAccessKey(@NotNull String accessKey) {
this.accessKey = accessKey;
return this;
}
- public Builder withSecretKey(@NonNull String secretKey) {
+ public Builder withSecretKey(@NotNull String secretKey) {
this.secretKey = secretKey;
return this;
}
- public Builder withSessionToken(@NonNull String sessionToken) {
+ public Builder withSessionToken(@NotNull String sessionToken) {
this.sessionToken = sessionToken;
return this;
}
- public Builder withRegion(@NonNull String region) {
+ public Builder withRegion(@NotNull String region) {
this.region = region;
return this;
}
- public Builder withHttpClient(@NonNull OkHttpClient httpClient) {
+ public Builder withHttpClient(@NotNull OkHttpClient httpClient) {
this.httpClient = httpClient;
return this;
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/CompleteMultipartUploadOutputModel.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/CompleteMultipartUploadOutputModel.java
index 654f3c8eb..9f1a4f2bc 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/CompleteMultipartUploadOutputModel.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/CompleteMultipartUploadOutputModel.java
@@ -19,7 +19,8 @@ public class CompleteMultipartUploadOutputModel {
@Element(name = "ETag")
private String etag;
- public CompleteMultipartUploadOutputModel() {}
+ public CompleteMultipartUploadOutputModel() {
+ }
public String location() {
return location;
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/UploadFilesResult.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/UploadFilesResult.java
index 43fe1de0f..f13ec9587 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/UploadFilesResult.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/model/UploadFilesResult.java
@@ -1,15 +1,71 @@
package io.milvus.bulkwriter.model;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
public class UploadFilesResult {
private String stageName;
private String path;
+
+ public UploadFilesResult() {
+ }
+
+ public UploadFilesResult(String stageName, String path) {
+ this.stageName = stageName;
+ this.path = path;
+ }
+
+ private UploadFilesResult(UploadFilesResultBuilder builder) {
+ this.stageName = builder.stageName;
+ this.path = builder.path;
+ }
+
+ public String getStageName() {
+ return stageName;
+ }
+
+ public void setStageName(String stageName) {
+ this.stageName = stageName;
+ }
+
+ public String getPath() {
+ return path;
+ }
+
+ public void setPath(String path) {
+ this.path = path;
+ }
+
+ @Override
+ public String toString() {
+ return "UploadFilesResult{" +
+ "stageName='" + stageName + '\'' +
+ ", path='" + path + '\'' +
+ '}';
+ }
+
+ public static UploadFilesResultBuilder builder() {
+ return new UploadFilesResultBuilder();
+ }
+
+ public static class UploadFilesResultBuilder {
+ private String stageName;
+ private String path;
+
+ private UploadFilesResultBuilder() {
+ this.stageName = "";
+ this.path = "";
+ }
+
+ public UploadFilesResultBuilder stageName(String stageName) {
+ this.stageName = stageName;
+ return this;
+ }
+
+ public UploadFilesResultBuilder path(String path) {
+ this.path = path;
+ return this;
+ }
+
+ public UploadFilesResult build() {
+ return new UploadFilesResult(this);
+ }
+ }
}
diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java
index 9fae25d6c..ee98abe80 100644
--- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java
+++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java
@@ -19,22 +19,61 @@
package io.milvus.bulkwriter.request.describe;
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-import lombok.experimental.SuperBuilder;
-
import java.io.Serializable;
-@Data
-@SuperBuilder(toBuilder = true)
-@AllArgsConstructor
-@NoArgsConstructor
public class BaseDescribeImportRequest implements Serializable {
private static final long serialVersionUID = -787626534606813089L;
+
/**
* 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;
+
+ public BaseDescribeImportRequest() {
+ }
+
+ public BaseDescribeImportRequest(String apiKey) {
+ this.apiKey = apiKey;
+ }
+
+ protected BaseDescribeImportRequest(BaseDescribeImportRequestBuilder builder) {
+ this.apiKey = builder.apiKey;
+ }
+
+ public String getApiKey() {
+ return apiKey;
+ }
+
+ public void setApiKey(String apiKey) {
+ this.apiKey = apiKey;
+ }
+
+ @Override
+ public String toString() {
+ return "BaseDescribeImportRequest{" +
+ "apiKey='" + apiKey + '\'' +
+ '}';
+ }
+
+ public static BaseDescribeImportRequestBuilder builder() {
+ return new BaseDescribeImportRequestBuilder<>();
+ }
+
+ public static class BaseDescribeImportRequestBuilder
MilvusClient
*/
@Deprecated
@@ -84,8 +91,8 @@ public interface MilvusClient {
/**
* Time interval between retry attempts. Default value is 500ms.
*
- * @param interval time interval between retry attempts.
- * @param timeUnit time unit
+ * @param interval time interval between retry attempts.
+ * @param timeUnit time unit
* @return MilvusClient
*/
@Deprecated
@@ -152,7 +159,7 @@ default void close() {
* Alter database with key value pair. (Available from Milvus v2.4.4)
*
* @param requestParam {@link AlterDatabaseParam}
- * @return {status:result code, data:RpcStatus{msg: result message}}
+ * @return {status:result code, data:RpcStatus{msg: result message}}
*/
R
* The info includes:
* 1. username(if Authentication is enabled)
* 2. the client computer's name
@@ -468,17 +471,17 @@ public void setLogLevel(LogLevel level) {
@Override
public R
* This method is copied from microsoft ONNX Runtime:
* https://github.com/microsoft/onnxruntime/blob/main/java/src/main/jvm/ai/onnxruntime/platform/Fp16Conversions.java
*
@@ -26,7 +26,7 @@ public static short floatToBf16(float input) {
/**
* Upcasts a bf16 value stored in a short into a float32 value.
- *
+ *
* This method is copied from microsoft ONNX Runtime:
* https://github.com/microsoft/onnxruntime/blob/main/java/src/main/jvm/ai/onnxruntime/platform/Fp16Conversions.java
*
@@ -40,7 +40,7 @@ public static float bf16ToFloat(short input) {
/**
* Rounds a float32 value to a fp16 stored in a short.
- *
+ *
* This method is copied from microsoft ONNX Runtime:
* https://github.com/microsoft/onnxruntime/blob/main/java/src/main/jvm/ai/onnxruntime/platform/Fp16Conversions.java
*
@@ -94,7 +94,7 @@ public static short floatToFp16(float input) {
/**
* Upcasts a fp16 value stored in a short to a float32 value.
- *
+ *
* This method is copied from microsoft ONNX Runtime:
* https://github.com/microsoft/onnxruntime/blob/main/java/src/main/jvm/ai/onnxruntime/platform/Fp16Conversions.java
*
diff --git a/sdk-core/src/main/java/io/milvus/common/utils/GTsDict.java b/sdk-core/src/main/java/io/milvus/common/utils/GTsDict.java
index 60773b588..72a08cd45 100644
--- a/sdk-core/src/main/java/io/milvus/common/utils/GTsDict.java
+++ b/sdk-core/src/main/java/io/milvus/common/utils/GTsDict.java
@@ -34,7 +34,8 @@ public class GTsDict {
// be passed to construct a guarantee_ts to the server.
private final static GTsDict TS_DICT = new GTsDict();
- private GTsDict(){}
+ private GTsDict() {
+ }
public static GTsDict getInstance() {
return TS_DICT;
diff --git a/sdk-core/src/main/java/io/milvus/common/utils/JsonUtils.java b/sdk-core/src/main/java/io/milvus/common/utils/JsonUtils.java
index afe9f0ffa..687d7aa4a 100644
--- a/sdk-core/src/main/java/io/milvus/common/utils/JsonUtils.java
+++ b/sdk-core/src/main/java/io/milvus/common/utils/JsonUtils.java
@@ -19,7 +19,10 @@
package io.milvus.common.utils;
-import com.google.gson.*;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.JsonElement;
+import com.google.gson.ToNumberPolicy;
import com.google.gson.reflect.TypeToken;
import java.lang.reflect.Type;
diff --git a/sdk-core/src/main/java/io/milvus/common/utils/URLParser.java b/sdk-core/src/main/java/io/milvus/common/utils/URLParser.java
index 702687e13..230f518eb 100644
--- a/sdk-core/src/main/java/io/milvus/common/utils/URLParser.java
+++ b/sdk-core/src/main/java/io/milvus/common/utils/URLParser.java
@@ -49,7 +49,7 @@ public URLParser(String url) {
// port
port = uri.getPort();
- if(port <= 0){
+ if (port <= 0) {
port = 19530;
}
diff --git a/sdk-core/src/main/java/io/milvus/exception/IllegalResponseException.java b/sdk-core/src/main/java/io/milvus/exception/IllegalResponseException.java
index d5ac6abbf..dd7740311 100644
--- a/sdk-core/src/main/java/io/milvus/exception/IllegalResponseException.java
+++ b/sdk-core/src/main/java/io/milvus/exception/IllegalResponseException.java
@@ -23,7 +23,7 @@
import io.milvus.param.R;
/**
- * Interfaces including
* Deprecated from v2.3.6, this flag is auto-detected, no need to specify
*
* @param enable true keep-alive
@@ -455,7 +455,7 @@ public Builder secure(boolean enable) {
* Sets the idle timeout value of client channel. The timeout value must be larger than zero.
*
* @param idleTimeout timeout value
- * @param timeUnit timeout unit
+ * @param timeUnit timeout unit
* @return
* Deprecated from v2.3.6, this flag is auto-detected, no need to specify
*
* @param secure boolean
@@ -511,6 +512,7 @@ public Builder withSecure(boolean secure) {
/**
* Sets the authorization for this connection
+ *
* @param authorization the encoded authorization info that has included the encoded username and password info
* @return Builder
*/
@@ -107,7 +106,7 @@ public Builder withFrom(ListBuilder
*/
@@ -121,6 +120,7 @@ public Builder withTo(ListBuilder
*/
@@ -194,30 +194,6 @@ public io.milvus.grpc.ResourceGroupConfig toGRPC() {
return builder.build();
}
- @Override
- public boolean equals(Object obj) {
- if (this == obj) return true;
- if (obj == null || getClass() != obj.getClass()) return false;
- ResourceGroupConfig that = (ResourceGroupConfig) obj;
- return new EqualsBuilder()
- .append(requests, that.requests)
- .append(limits, that.limits)
- .append(from, that.from)
- .append(to, that.to)
- .append(nodeFilter, that.nodeFilter)
- .isEquals();
- }
-
- @Override
- public int hashCode() {
- int result = requests != null ? requests.hashCode() : 0;
- result = 31 * result + (limits != null ? limits.hashCode() : 0);
- result = 31 * result + (from != null ? from.hashCode() : 0);
- result = 31 * result + (to != null ? to.hashCode() : 0);
- result = 31 * result + (nodeFilter != null ? nodeFilter.hashCode() : 0);
- return result;
- }
-
@Override
public String toString() {
return "ResourceGroupConfig{" +
diff --git a/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupLimit.java b/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupLimit.java
index 8aaf26764..b49227832 100644
--- a/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupLimit.java
+++ b/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupLimit.java
@@ -19,14 +19,12 @@
package io.milvus.common.resourcegroup;
-import org.apache.commons.lang3.builder.EqualsBuilder;
-
public class ResourceGroupLimit {
private Integer nodeNum;
/**
* Constructor with node number.
- *
+ *
* @param nodeNum query node number in this group
*/
public ResourceGroupLimit(Integer nodeNum) {
@@ -38,7 +36,7 @@ public ResourceGroupLimit(Integer nodeNum) {
/**
* Constructor from grpc
- *
+ *
* @param grpcLimit grpc object to set limit of node number
*/
public ResourceGroupLimit(io.milvus.grpc.ResourceGroupLimit grpcLimit) {
@@ -50,7 +48,7 @@ public ResourceGroupLimit(io.milvus.grpc.ResourceGroupLimit grpcLimit) {
/**
* Transfer to grpc
- *
+ *
* @return io.milvus.grpc.ResourceGroupLimit
*/
public io.milvus.grpc.ResourceGroupLimit toGRPC() {
@@ -71,23 +69,4 @@ public String toString() {
"nodeNum=" + nodeNum +
'}';
}
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- }
- if (obj == null || getClass() != obj.getClass()) {
- return false;
- }
- ResourceGroupLimit that = (ResourceGroupLimit) obj;
- return new EqualsBuilder()
- .append(nodeNum, that.nodeNum)
- .isEquals();
- }
-
- @Override
- public int hashCode() {
- return nodeNum != null ? nodeNum.hashCode() : 0;
- }
}
diff --git a/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupNodeFilter.java b/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupNodeFilter.java
index f73cfc6eb..df35659a6 100644
--- a/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupNodeFilter.java
+++ b/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupNodeFilter.java
@@ -19,16 +19,14 @@
package io.milvus.common.resourcegroup;
+import io.milvus.grpc.KeyValuePair;
+import io.milvus.param.ParamUtils;
+
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.Objects;
import java.util.stream.Collectors;
-import io.milvus.grpc.KeyValuePair;
-import io.milvus.param.ParamUtils;
-import org.apache.commons.lang3.builder.EqualsBuilder;
-
public class ResourceGroupNodeFilter {
private final MapBuilder
*/
@@ -96,6 +97,7 @@ public ResourceGroupNodeFilter build() {
/**
* Transfer to grpc
+ *
* @return io.milvus.grpc.ResourceGroupNodeFilter
*/
public io.milvus.grpc.ResourceGroupNodeFilter toGRPC() {
@@ -103,7 +105,7 @@ public io.milvus.grpc.ResourceGroupNodeFilter toGRPC() {
io.milvus.grpc.ResourceGroupNodeFilter result = io.milvus.grpc.ResourceGroupNodeFilter.newBuilder()
.addAllNodeLabels(pair)
.build();
-
+
// Replace @NonNull logic with explicit null check
if (result == null) {
throw new IllegalStateException("Failed to create GRPC ResourceGroupNodeFilter");
@@ -111,25 +113,6 @@ public io.milvus.grpc.ResourceGroupNodeFilter toGRPC() {
return result;
}
- @Override
- public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- }
- if (obj == null || getClass() != obj.getClass()) {
- return false;
- }
- ResourceGroupNodeFilter that = (ResourceGroupNodeFilter) obj;
- return new EqualsBuilder()
- .append(nodeLabels, that.nodeLabels)
- .isEquals();
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(nodeLabels);
- }
-
@Override
public String toString() {
return "ResourceGroupNodeFilter{" +
diff --git a/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupTransfer.java b/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupTransfer.java
index 11e5b0f3b..847e0ae09 100644
--- a/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupTransfer.java
+++ b/sdk-core/src/main/java/io/milvus/common/resourcegroup/ResourceGroupTransfer.java
@@ -24,7 +24,7 @@ public class ResourceGroupTransfer {
/**
* Constructor with resource group name.
- *
+ *
* @param resourceGroupName resource group name
*/
public ResourceGroupTransfer(String resourceGroupName) {
@@ -36,7 +36,7 @@ public ResourceGroupTransfer(String resourceGroupName) {
/**
* Constructor from grpc
- *
+ *
* @param grpcTransfer grpc transfer object
*/
public ResourceGroupTransfer(io.milvus.grpc.ResourceGroupTransfer grpcTransfer) {
@@ -48,7 +48,7 @@ public ResourceGroupTransfer(io.milvus.grpc.ResourceGroupTransfer grpcTransfer)
/**
* Get resource group name
- *
+ *
* @return resource group name
*/
public String getResourceGroupName() {
@@ -57,14 +57,14 @@ public String getResourceGroupName() {
/**
* Transfer to grpc
- *
+ *
* @return io.milvus.grpc.ResourceGroupTransfer
*/
public io.milvus.grpc.ResourceGroupTransfer toGRPC() {
io.milvus.grpc.ResourceGroupTransfer result = io.milvus.grpc.ResourceGroupTransfer.newBuilder()
.setResourceGroup(resourceGroupName)
.build();
-
+
if (result == null) {
throw new IllegalStateException("Failed to create GRPC ResourceGroupTransfer");
}
diff --git a/sdk-core/src/main/java/io/milvus/common/utils/Float16Utils.java b/sdk-core/src/main/java/io/milvus/common/utils/Float16Utils.java
index 60d646d1e..1ec374f79 100644
--- a/sdk-core/src/main/java/io/milvus/common/utils/Float16Utils.java
+++ b/sdk-core/src/main/java/io/milvus/common/utils/Float16Utils.java
@@ -9,7 +9,7 @@
public class Float16Utils {
/**
* Converts a float32 into bf16. May not produce correct values for subnormal floats.
- *
+ * search/search/loadCollection might
+ * Interfaces including search/search/loadCollection might
* throw this exception when server return illegal response. It may indicate a bug in server.
*/
public class IllegalResponseException extends MilvusException {
diff --git a/sdk-core/src/main/java/io/milvus/exception/ServerException.java b/sdk-core/src/main/java/io/milvus/exception/ServerException.java
index 15e303e2c..b30513d72 100644
--- a/sdk-core/src/main/java/io/milvus/exception/ServerException.java
+++ b/sdk-core/src/main/java/io/milvus/exception/ServerException.java
@@ -20,13 +20,13 @@
package io.milvus.exception;
import io.milvus.grpc.ErrorCode;
-import io.milvus.param.R;
/**
* Exception for error response from server side.
*/
public class ServerException extends MilvusException {
protected ErrorCode compatibleCode;
+
public ServerException(String msg, Integer code, ErrorCode compatibleCode) {
super(msg, code);
this.compatibleCode = compatibleCode;
diff --git a/sdk-core/src/main/java/io/milvus/orm/iterator/IteratorAdapterV2.java b/sdk-core/src/main/java/io/milvus/orm/iterator/IteratorAdapterV2.java
index 479d9316a..952e334a6 100644
--- a/sdk-core/src/main/java/io/milvus/orm/iterator/IteratorAdapterV2.java
+++ b/sdk-core/src/main/java/io/milvus/orm/iterator/IteratorAdapterV2.java
@@ -25,8 +25,8 @@
import io.milvus.grpc.PlaceholderType;
import io.milvus.param.MetricType;
import io.milvus.param.collection.FieldType;
-import io.milvus.param.dml.SearchIteratorParam;
import io.milvus.param.dml.QueryIteratorParam;
+import io.milvus.param.dml.SearchIteratorParam;
import io.milvus.v2.common.IndexParam;
import io.milvus.v2.service.collection.request.CreateCollectionReq;
import io.milvus.v2.service.vector.request.QueryIteratorReq;
@@ -58,6 +58,7 @@ public static QueryIteratorParam convertV2Req(QueryIteratorReq queryIteratorReq)
return builder.build();
}
+
public static SearchIteratorParam convertV2Req(SearchIteratorReq searchIteratorReq) {
MetricType metricType = MetricType.None;
if (searchIteratorReq.getMetricType() != IndexParam.MetricType.INVALID) {
@@ -94,31 +95,31 @@ public static SearchIteratorParam convertV2Req(SearchIteratorReq searchIteratorR
switch (plType) {
case FloatVector: {
ListBuilder
*/
- public Builder withPort(int port) {
+ public Builder withPort(int port) {
this.port = port;
return this;
}
@@ -383,7 +383,7 @@ public Builder withToken(String token) {
* Sets the connection timeout value of client channel. The timeout value must be greater than zero.
*
* @param connectTimeout timeout value
- * @param timeUnit timeout unit
+ * @param timeUnit timeout unit
* @return Builder
*/
public Builder withConnectTimeout(long connectTimeout, TimeUnit timeUnit) {
@@ -399,7 +399,7 @@ public Builder withConnectTimeout(long connectTimeout, TimeUnit timeUnit) {
* Default is 55000 ms.
*
* @param keepAliveTime keep-alive value
- * @param timeUnit keep-alive unit
+ * @param timeUnit keep-alive unit
* @return Builder
*/
public Builder withKeepAliveTime(long keepAliveTime, TimeUnit timeUnit) {
@@ -415,7 +415,7 @@ public Builder withKeepAliveTime(long keepAliveTime, TimeUnit timeUnit) {
* Default value is 20000 ms
*
* @param keepAliveTimeout timeout value
- * @param timeUnit timeout unit
+ * @param timeUnit timeout unit
* @return Builder
*/
public Builder withKeepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit) {
@@ -439,7 +439,7 @@ public Builder keepAliveWithoutCalls(boolean enable) {
/**
* Enables the secure for client channel.
- *
+ * Builder
*/
public Builder withIdleTimeout(long idleTimeout, TimeUnit timeUnit) {
@@ -485,6 +485,7 @@ public Builder withRpcDeadline(long deadline, TimeUnit timeUnit) {
/**
* Sets the username and password for this connection
+ *
* @param username current user
* @param password password
* @return Builder
@@ -497,7 +498,7 @@ public Builder withAuthorization(String username, String password) {
/**
* Sets secure the authorization for this connection, set to True to enable TLS
- *
+ * Builder
*/
@@ -524,6 +526,7 @@ public Builder withAuthorization(String authorization) {
/**
* Set the client.key path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param clientKeyPath path of client.key
* @return Builder
*/
@@ -537,6 +540,7 @@ public Builder withClientKeyPath(String clientKeyPath) {
/**
* Set the client.pem path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param clientPemPath path of client.pem
* @return Builder
*/
@@ -550,6 +554,7 @@ public Builder withClientPemPath(String clientPemPath) {
/**
* Set the ca.pem path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param caPemPath path of ca.pem
* @return Builder
*/
@@ -563,6 +568,7 @@ public Builder withCaPemPath(String caPemPath) {
/**
* Set the server.pem path for tls one-way authentication, only takes effect when "secure" is True.
+ *
* @param serverPemPath path of server.pem
* @return Builder
*/
@@ -577,6 +583,7 @@ public Builder withServerPemPath(String serverPemPath) {
/**
* Set target name override for SSL host name checking, only takes effect when "secure" is True.
* Note: this value is passed to grpc.ssl_target_name_override
+ *
* @param serverName override name for SSL host
* @return Builder
*/
@@ -595,10 +602,10 @@ public Builder withClientRequestId(ThreadLocalBuilder
*/
@@ -631,7 +638,7 @@ protected void verify() throws ParamException {
}
}
- if(host.startsWith(HOST_HTTPS_PREFIX)){
+ if (host.startsWith(HOST_HTTPS_PREFIX)) {
this.secure = true;
}
diff --git a/sdk-core/src/main/java/io/milvus/param/Constant.java b/sdk-core/src/main/java/io/milvus/param/Constant.java
index 1987e9974..d9a74c9b1 100644
--- a/sdk-core/src/main/java/io/milvus/param/Constant.java
+++ b/sdk-core/src/main/java/io/milvus/param/Constant.java
@@ -87,9 +87,9 @@ public class Constant {
public static final Long GUARANTEE_STRONG_TS = 0L;
// high level api
- public static final String VECTOR_FIELD_NAME_DEFAULT = "vector";
+ public static final String VECTOR_FIELD_NAME_DEFAULT = "vector";
public static final String PRIMARY_FIELD_NAME_DEFAULT = "id";
- public static final String VECTOR_INDEX_NAME_DEFAULT = "vector_idx";
+ public static final String VECTOR_INDEX_NAME_DEFAULT = "vector_idx";
public static final Long LIMIT_DEFAULT = 100L;
public static final Long OFFSET_DEFAULT = 0L;
public static final String ALL_OUTPUT_FIELDS = "*";
diff --git a/sdk-core/src/main/java/io/milvus/param/IndexType.java b/sdk-core/src/main/java/io/milvus/param/IndexType.java
index 083d8d78a..11d513dc3 100644
--- a/sdk-core/src/main/java/io/milvus/param/IndexType.java
+++ b/sdk-core/src/main/java/io/milvus/param/IndexType.java
@@ -57,23 +57,22 @@ public enum IndexType {
// Only for sparse vectors
SPARSE_INVERTED_INDEX(300),
- SPARSE_WAND(301)
- ;
+ SPARSE_WAND(301);
private final String name;
private final int code;
- IndexType(){
+ IndexType() {
this.name = this.name();
this.code = this.ordinal();
}
- IndexType(int code){
+ IndexType(int code) {
this.name = this.name();
this.code = code;
}
- IndexType(String name, int code){
+ IndexType(String name, int code) {
this.name = name;
this.code = code;
}
diff --git a/sdk-core/src/main/java/io/milvus/param/MultiConnectParam.java b/sdk-core/src/main/java/io/milvus/param/MultiConnectParam.java
index 18cb5334e..d333941e7 100644
--- a/sdk-core/src/main/java/io/milvus/param/MultiConnectParam.java
+++ b/sdk-core/src/main/java/io/milvus/param/MultiConnectParam.java
@@ -124,7 +124,7 @@ public Builder withHost(String host) {
* @param port port value
* @return Builder
*/
- public Builder withPort(int port) {
+ public Builder withPort(int port) {
super.withPort(port);
return this;
}
@@ -166,7 +166,7 @@ public Builder withToken(String token) {
* Sets the connection timeout value of client channel. The timeout value must be greater than zero.
*
* @param connectTimeout timeout value
- * @param timeUnit timeout unit
+ * @param timeUnit timeout unit
* @return Builder
*/
public Builder withConnectTimeout(long connectTimeout, TimeUnit timeUnit) {
@@ -181,7 +181,7 @@ public Builder withConnectTimeout(long connectTimeout, TimeUnit timeUnit) {
* Sets the keep-alive time value of client channel. The keep-alive value must be greater than zero.
*
* @param keepAliveTime keep-alive value
- * @param timeUnit keep-alive unit
+ * @param timeUnit keep-alive unit
* @return Builder
*/
public Builder withKeepAliveTime(long keepAliveTime, TimeUnit timeUnit) {
@@ -196,7 +196,7 @@ public Builder withKeepAliveTime(long keepAliveTime, TimeUnit timeUnit) {
* Sets the keep-alive timeout value of client channel. The timeout value must be greater than zero.
*
* @param keepAliveTimeout timeout value
- * @param timeUnit timeout unit
+ * @param timeUnit timeout unit
* @return Builder
*/
public Builder withKeepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit) {
@@ -222,7 +222,7 @@ public Builder keepAliveWithoutCalls(boolean enable) {
* Sets the idle timeout value of client channel. The timeout value must be larger than zero.
*
* @param idleTimeout timeout value
- * @param timeUnit timeout unit
+ * @param timeUnit timeout unit
* @return Builder
*/
public Builder withIdleTimeout(long idleTimeout, TimeUnit timeUnit) {
@@ -252,6 +252,7 @@ public Builder withRpcDeadline(long deadline, TimeUnit timeUnit) {
/**
* Sets the username and password for this connection
+ *
* @param username current user
* @param password password
* @return Builder
@@ -263,6 +264,7 @@ public Builder withAuthorization(String username, String password) {
/**
* Sets secure the authorization for this connection, set to True to enable TLS
+ *
* @param secure boolean
* @return Builder
*/
@@ -273,6 +275,7 @@ public Builder withSecure(boolean secure) {
/**
* Sets the secure for this connection
+ *
* @param authorization the authorization info that has included the encoded username and password info
* @return Builder
*/
@@ -286,6 +289,7 @@ public Builder withAuthorization(String authorization) {
/**
* Set the client.key path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param clientKeyPath path of client.key
* @return Builder
*/
@@ -299,6 +303,7 @@ public Builder withClientKeyPath(String clientKeyPath) {
/**
* Set the client.pem path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param clientPemPath path of client.pem
* @return Builder
*/
@@ -312,6 +317,7 @@ public Builder withClientPemPath(String clientPemPath) {
/**
* Set the ca.pem path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param caPemPath path of ca.pem
* @return Builder
*/
@@ -325,6 +331,7 @@ public Builder withCaPemPath(String caPemPath) {
/**
* Set the server.pem path for tls two-way authentication, only takes effect when "secure" is True.
+ *
* @param serverPemPath path of server.pem
* @return Builder
*/
@@ -339,6 +346,7 @@ public Builder withServerPemPath(String serverPemPath) {
/**
* Set target name override for SSL host name checking, only takes effect when "secure" is True.
* Note: this value is passed to grpc.ssl_target_name_override
+ *
* @param serverName path of server.pem
* @return Builder
*/
@@ -366,10 +374,10 @@ public MultiConnectParam build() throws ParamException {
for (ServerAddress serverAddress : hosts) {
String host = serverAddress.getHost();
ParamUtils.CheckNullEmptyString(host, "Host name");
- if(host.startsWith(HOST_HTTPS_PREFIX)){
+ if (host.startsWith(HOST_HTTPS_PREFIX)) {
host = host.replace(HOST_HTTPS_PREFIX, "");
this.secure = true;
- }else if(host.startsWith(HOST_HTTP_PREFIX)){
+ } else if (host.startsWith(HOST_HTTP_PREFIX)) {
host = host.replace(HOST_HTTP_PREFIX, "");
}
hostAddress.add(ServerAddress.newBuilder()
diff --git a/sdk-core/src/main/java/io/milvus/param/ParamUtils.java b/sdk-core/src/main/java/io/milvus/param/ParamUtils.java
index 540423720..0bdba579c 100644
--- a/sdk-core/src/main/java/io/milvus/param/ParamUtils.java
+++ b/sdk-core/src/main/java/io/milvus/param/ParamUtils.java
@@ -98,15 +98,15 @@ public static void checkFieldData(FieldType fieldSchema, InsertParam.Field field
public static int calculateBinVectorDim(DataType dataType, int byteCount) {
if (dataType == DataType.BinaryVector) {
- return byteCount*8; // for BinaryVector, each byte is 8 dimensions
+ return byteCount * 8; // for BinaryVector, each byte is 8 dimensions
} else if (dataType == DataType.Int8Vector) {
return byteCount; // for Int8Vector, each byte is one dimension
} else {
- if (byteCount%2 != 0) {
+ if (byteCount % 2 != 0) {
String msg = "Incorrect byte count for %s type field, byte count is %d, cannot be evenly divided by 2";
throw new ParamException(String.format(msg, dataType.name(), byteCount));
}
- return byteCount/2; // for float16/bfloat16, each dimension is 2 bytes
+ return byteCount / 2; // for float16/bfloat16, each dimension is 2 bytes
}
}
@@ -155,12 +155,12 @@ public static void checkFieldData(FieldType fieldSchema, List values, boolean
int dim = fieldSchema.getDimension();
for (int i = 0; i < values.size(); ++i) {
// is List<> ?
- Object value = values.get(i);
+ Object value = values.get(i);
if (!(value instanceof List)) {
throw new ParamException(String.format(errMsgs.get(dataType), fieldSchema.getName()));
}
// is List