pretty code style for newest branch (#211)

* pretty code style for newest branch

Signed-off-by: ChunelFeng <chunel@foxmail.com>

* pretty example code style ...

Signed-off-by: ChunelFeng <chunel@foxmail.com>

examples/main/io/milvus/DDLExample.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus;
 
 import io.milvus.client.MilvusServiceClient;
@@ -58,7 +77,7 @@ public class DDLExample {
     }
 
     @Test
-    public void createCollection(){
+    public void createCollection() {
         FieldType[] fieldTypes = new FieldType[2];
         FieldType fieldType1 = FieldType.Builder.newBuilder()
                 .withName("userID")
@@ -67,8 +86,8 @@ public class DDLExample {
                 .withAutoID(true)
                 .withPrimaryKey(true).build();
 
-        Map<String,String> typeParamsMap = new HashMap<>();
-        typeParamsMap.put("dim","512");
+        Map<String, String> typeParamsMap = new HashMap<>();
+        typeParamsMap.put("dim", "512");
         FieldType fieldType2 = FieldType.Builder.newBuilder()
                 .withName("vector1")
                 .withDescription("match Vector")
@@ -88,7 +107,7 @@ public class DDLExample {
     }
 
     @Test
-    public void dropCollection(){
+    public void dropCollection() {
         R<RpcStatus> dropCollection = milvusClient.dropCollection(DropCollectionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -97,7 +116,7 @@ public class DDLExample {
     }
 
     @Test
-    public void hasCollection(){
+    public void hasCollection() {
         R<Boolean> hasCollection = milvusClient.hasCollection(HasCollectionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -107,7 +126,7 @@ public class DDLExample {
     }
 
     @Test
-    public void loadCollection(){
+    public void loadCollection() {
         R<RpcStatus> loadCollection = milvusClient.loadCollection(LoadCollectionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -116,7 +135,7 @@ public class DDLExample {
     }
 
     @Test
-    public void releaseCollection(){
+    public void releaseCollection() {
         R<RpcStatus> releaseCollection = milvusClient.releaseCollection(ReleaseCollectionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -125,7 +144,7 @@ public class DDLExample {
     }
 
     @Test
-    public void describeCollection(){
+    public void describeCollection() {
         R<DescribeCollectionResponse> describeCollection = milvusClient.describeCollection(DescribeCollectionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -134,7 +153,7 @@ public class DDLExample {
     }
 
     @Test
-    public void getCollectionStatistics(){
+    public void getCollectionStatistics() {
         R<GetCollectionStatisticsResponse> getCollectionStatistics = milvusClient.getCollectionStatistics(GetCollectionStatisticsParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -143,7 +162,7 @@ public class DDLExample {
     }
 
     @Test
-    public void showCollections(){
+    public void showCollections() {
         String[] collectionNames = new String[]{"collection1"};
         R<ShowCollectionsResponse> showCollections = milvusClient.showCollections(ShowCollectionParam.Builder
                 .newBuilder()
@@ -154,7 +173,7 @@ public class DDLExample {
     }
 
     @Test
-    public void createPartition(){
+    public void createPartition() {
         R<RpcStatus> createPartition = milvusClient.createPartition(CreatePartitionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -165,7 +184,7 @@ public class DDLExample {
     }
 
     @Test
-    public void dropPartition(){
+    public void dropPartition() {
         R<RpcStatus> dropPartition = milvusClient.dropPartition(DropPartitionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -176,7 +195,7 @@ public class DDLExample {
     }
 
     @Test
-    public void hasPartition(){
+    public void hasPartition() {
         R<Boolean> hasPartition = milvusClient.hasPartition(HasPartitionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -187,7 +206,7 @@ public class DDLExample {
     }
 
     @Test
-    public void loadPartitions(){
+    public void loadPartitions() {
         String[] partitionNames = new String[]{"par1"};
         R<RpcStatus> loadPartition = milvusClient.loadPartitions(LoadPartitionsParam.Builder
                 .newBuilder()
@@ -199,7 +218,7 @@ public class DDLExample {
     }
 
     @Test
-    public void releasePartitions(){
+    public void releasePartitions() {
         String[] releaseNames = new String[]{"par1"};
         R<RpcStatus> releasePartition = milvusClient.releasePartitions(ReleasePartitionsParam.Builder
                 .newBuilder()
@@ -211,7 +230,7 @@ public class DDLExample {
     }
 
     @Test
-    public void getPartitionStatistics(){
+    public void getPartitionStatistics() {
         R<GetPartitionStatisticsResponse> getPartitionStatistics = milvusClient.getPartitionStatistics(GetPartitionStatisticsParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -222,7 +241,7 @@ public class DDLExample {
     }
 
     @Test
-    public void showPartitions(){
+    public void showPartitions() {
         R<ShowPartitionsResponse> showPartitionsResponse = milvusClient.showPartitions(ShowPartitionParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -231,11 +250,11 @@ public class DDLExample {
     }
 
     @Test
-    public void createIndex(){
-        Map<String,String> extraParam = new HashMap<>();
-        extraParam.put("index_type","IVF_FLAT");
+    public void createIndex() {
+        Map<String, String> extraParam = new HashMap<>();
+        extraParam.put("index_type", "IVF_FLAT");
         extraParam.put("metric_type", "IP");
-        extraParam.put("params","{\"nlist\":10}");
+        extraParam.put("params", "{\"nlist\":10}");
         R<RpcStatus> createIndex = milvusClient.createIndex(CreateIndexParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -246,7 +265,7 @@ public class DDLExample {
     }
 
     @Test
-    public void dropIndex(){
+    public void dropIndex() {
         R<RpcStatus> dropIndex = milvusClient.dropIndex(DropIndexParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -256,7 +275,7 @@ public class DDLExample {
     }
 
     @Test
-    public void describeIndex(){
+    public void describeIndex() {
         R<DescribeIndexResponse> describeIndex = milvusClient.describeIndex(DescribeIndexParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -266,7 +285,7 @@ public class DDLExample {
     }
 
     @Test
-    public void getIndexState(){
+    public void getIndexState() {
         R<GetIndexStateResponse> getIndexState = milvusClient.getIndexState(GetIndexStateParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")
@@ -276,7 +295,7 @@ public class DDLExample {
     }
 
     @Test
-    public void getIndexBuildProgress(){
+    public void getIndexBuildProgress() {
         R<GetIndexBuildProgressResponse> getIndexBuildProgress = milvusClient.getIndexBuildProgress(GetIndexBuildProgressParam.Builder
                 .newBuilder()
                 .withCollectionName("collection1")

examples/main/io/milvus/DMLExample.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus;
 
 import com.google.protobuf.ByteString;
@@ -54,7 +73,7 @@ public class DMLExample {
         result.add(vectors);
 
         InsertParam insertParam = InsertParam.Builder
-                .nweBuilder(collectionName)
+                .newBuilder(collectionName)
                 .setFieldNum(fieldNames.size())
                 .setFieldNames(fieldNames)
                 .setPartitionName(partitionName)
@@ -65,9 +84,7 @@ public class DMLExample {
         R<MutationResult> insert = milvusClient.insert(insertParam);
         System.out.println(insert.getData());
 
-
         R<FlushResponse> flush = milvusClient.flush(collectionName);
-
         System.out.println(flush.getData());
     }
 
@@ -75,7 +92,7 @@ public class DMLExample {
     public void delete() {
         String collectionName = "test";
         String partitionName = "pT";
-        DeleteParam build = DeleteParam.Builder.nweBuilder()
+        DeleteParam build = DeleteParam.Builder.newBuilder()
                 .setCollectionName(collectionName)
                 .setPartitionName(partitionName)
                 .build();

src/main/java/io/milvus/client/AbstractMilvusGrpcClient.java

@@ -1,18 +1,42 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.client;
 
 import com.google.protobuf.ByteString;
 import io.grpc.StatusRuntimeException;
-import io.milvus.exception.ParamException;
-import io.milvus.grpc.*;
-import io.milvus.param.*;
-import io.milvus.param.dml.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import java.nio.ByteBuffer;
 import java.util.*;
 import java.util.stream.Collectors;
-import io.grpc.StatusRuntimeException;
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+import io.milvus.exception.ParamException;
+import io.milvus.grpc.*;
+import io.milvus.param.*;
+import io.milvus.param.dml.*;
 import io.milvus.grpc.BoolResponse;
 import io.milvus.grpc.CollectionSchema;
 import io.milvus.grpc.CreateCollectionRequest;
@@ -75,13 +99,6 @@ import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 
-import java.lang.reflect.Field;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-
 public abstract class AbstractMilvusGrpcClient implements MilvusClient {
 
     private static final Logger logger = LoggerFactory.getLogger(AbstractMilvusGrpcClient.class);
@@ -92,8 +109,6 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
 
     protected abstract boolean maybeAvailable();
 
-
-
     @Override
     public R<FlushResponse> flush(String collectionName, String dbName) {
         return flush(Collections.singletonList(collectionName), dbName);
@@ -102,13 +117,11 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
     @Override
     public R<FlushResponse> flush(String collectionName) {
         return flush(Collections.singletonList(collectionName), "");
-
     }
 
     @Override
     public R<FlushResponse> flush(List<String> collectionNames) {
         return flush(collectionNames, "");
-
     }
 
     @Override
@@ -187,7 +200,6 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
             R.failed(e);
         }
         return R.success(insert);
-
     }
 
     @Override
@@ -209,7 +221,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
 
 
         PlaceholderValue.Builder pldBuilder = PlaceholderValue.newBuilder()
-                .setTag(Constant.vectorTag)
+                .setTag(Constant.VECTOR_TAG)
                 .setType(PlaceholderType.FloatVector);
         byteStrings.forEach(pldBuilder::addValues);
 
@@ -221,26 +233,26 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
 
         builder.addSearchParams(
                         KeyValuePair.newBuilder()
-                                .setKey(Constant.vectorFiled)
+                                .setKey(Constant.VECTOR_FIELD)
                                 .setValue(searchParam.getVectorFieldName())
                                 .build())
                 .addSearchParams(
                         KeyValuePair.newBuilder()
-                                .setKey(Constant.topK)
+                                .setKey(Constant.TOP_K)
                                 .setValue(String.valueOf(searchParam.getTopK()))
                                 .build())
                 .addSearchParams(
                         KeyValuePair.newBuilder()
-                                .setKey(Constant.metricType)
+                                .setKey(Constant.METRIC_TYPE)
                                 .setValue(searchParam.getMetricType().name())
                                 .build());
 
-        if (!searchParam.getParams().isEmpty() && null != searchParam.getParams().get(Constant.parmas)
-                && !searchParam.getParams().get(Constant.parmas).isEmpty()) {
+        if (!searchParam.getParams().isEmpty() && null != searchParam.getParams().get(Constant.PARAMS)
+                && !searchParam.getParams().get(Constant.PARAMS).isEmpty()) {
             builder.addSearchParams(
                     KeyValuePair.newBuilder()
-                            .setKey(Constant.parmas)
-                            .setValue(searchParam.getParams().get(Constant.parmas))
+                            .setKey(Constant.PARAMS)
+                            .setValue(searchParam.getParams().get(Constant.PARAMS))
                             .build());
         }
 
@@ -254,8 +266,6 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
         }
 
         SearchRequest searchRequest = builder.build();
-
-
         SearchResults search;
         try {
             search = this.blockingStub().search(searchRequest);
@@ -350,7 +360,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
                         List list = (List) object;
                         list.forEach(o -> floats.add((Float) o));
                     } else {
-                        throw new ParamException("参数有问题");
+                        throw new ParamException("param type unsuitable");
                     }
                 }
                 int dim = floats.size() / objects.size();
@@ -359,14 +369,11 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
                 return builder.setFieldName(fieldName).setType(DataType.FloatVector).setVectors(vectorField).build();
             } else if (dataType == DataType.BinaryVector) {
                 List<ByteBuffer> bytes = objects.stream().map(p -> (ByteBuffer) p).collect(Collectors.toList());
-                ;
                 ByteString byteString = ByteString.copyFrom((ByteBuffer) bytes);
                 int dim = objects.size();
                 VectorField vectorField = VectorField.newBuilder().setDim(dim).setBinaryVector(byteString).build();
                 return builder.setFieldName(fieldName).setType(DataType.BinaryVector).setVectors(vectorField).build();
             }
-
-
         } else {
             switch (dataType) {
                 case None:
@@ -406,6 +413,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
                     return builder.setFieldName(fieldName).setType(dataType).setScalars(scalarField6).build();
             }
         }
+
         return null;
     }
 
@@ -434,19 +442,17 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
             response = blockingStub().hasCollection(hasCollectionRequest);
             if (response.getStatus().getErrorCode() == ErrorCode.Success) {
                 logInfo("Has collection check successfully!\n{}", requestParam.toString());
-                Boolean aBoolean = Optional.ofNullable(response)
+                Boolean value = Optional.of(response)
                         .map(BoolResponse::getValue)
                         .orElse(false);
-                return R.success(aBoolean);
+                return R.success(value);
             } else {
                 return R.failed(R.Status.valueOf(response.getStatus().getErrorCode().getNumber()));
             }
-
         } catch (StatusRuntimeException e) {
             logger.error("[milvus] hasCollection:{} request error: {}", requestParam.getCollectionName(), e.getMessage());
             return R.failed(e);
         }
-
     }
 
 
@@ -466,8 +472,7 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
         // Construct CollectionSchema Params
         CollectionSchema.Builder collectionSchemaBuilder = CollectionSchema.newBuilder();
         collectionSchemaBuilder.setName(requestParam.getCollectionName())
-                               .setDescription(requestParam.getDescription());
-
+                .setDescription(requestParam.getDescription());
 
         for (FieldType fieldType : requestParam.getFieldTypes()) {
             FieldSchema.Builder fieldSchemaBuilder = FieldSchema.newBuilder()
@@ -501,7 +506,6 @@ public abstract class AbstractMilvusGrpcClient implements MilvusClient {
                 .build();
 
         Status response;
-
         try {
             response = blockingStub().createCollection(createCollectionRequest);
 

src/main/java/io/milvus/client/MilvusClient.java

@@ -19,10 +19,11 @@
 
 package io.milvus.client;
 
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
 import io.milvus.grpc.*;
 import io.milvus.param.*;
-
-import java.util.List;
 import io.milvus.grpc.DescribeCollectionResponse;
 import io.milvus.grpc.DescribeIndexResponse;
 import io.milvus.grpc.GetCollectionStatisticsResponse;
@@ -54,34 +55,32 @@ import io.milvus.param.partition.LoadPartitionsParam;
 import io.milvus.param.partition.ReleasePartitionsParam;
 import io.milvus.param.partition.ShowPartitionParam;
 
-import java.util.concurrent.TimeUnit;
-
 /** The Milvus Client Interface */
 public interface MilvusClient {
 
-  default void close() {
-    close(TimeUnit.MINUTES.toSeconds(1));
-  }
+    default void close() {
+        close(TimeUnit.MINUTES.toSeconds(1));
+    }
 
-  void close(long maxWaitSeconds);
+    void close(long maxWaitSeconds);
 
-  R<MutationResult> insert(InsertParam insertParam);
+    R<MutationResult> insert(InsertParam insertParam);
 
-  R<FlushResponse> flush(String collectionName,String dbName);
+    R<FlushResponse> flush(String collectionName, String dbName);
 
-  R<FlushResponse> flush(String collectionName);
+    R<FlushResponse> flush(String collectionName);
 
-  R<FlushResponse> flush(List<String> collectionNames);
+    R<FlushResponse> flush(List<String> collectionNames);
 
-  R<FlushResponse> flush(List<String> collectionNames, String dbName);
+    R<FlushResponse> flush(List<String> collectionNames, String dbName);
 
-  R<MutationResult> delete(DeleteParam deleteParam);
+    R<MutationResult> delete(DeleteParam deleteParam);
 
-  R<SearchResults> search(SearchParam searchParam);
+    R<SearchResults> search(SearchParam searchParam);
 
-  R<QueryResults> query(QueryParam queryParam);
+    R<QueryResults> query(QueryParam queryParam);
 
-  R<CalcDistanceResults> calcDistance(CalcDistanceParam calcDistanceParam);
+    R<CalcDistanceResults> calcDistance(CalcDistanceParam calcDistanceParam);
 
     /**
      * Check if a collection exists.
@@ -192,7 +191,7 @@ public interface MilvusClient {
      * Show the statistics information of a partition.
      *
      * @param requestParam {@link GetPartitionStatisticsParam}
-     * @return  {status:result code,data:GetPartitionStatisticsResponse{status,stats}}
+     * @return {status:result code,data:GetPartitionStatisticsResponse{status,stats}}
      */
     R<GetPartitionStatisticsResponse> getPartitionStatistics(GetPartitionStatisticsParam requestParam);
 

src/main/java/io/milvus/client/MilvusServiceClient.java

@@ -71,7 +71,5 @@ public class MilvusServiceClient extends AbstractMilvusGrpcClient {
     public void close(long maxWaitSeconds) {
 
     }
-
-
 }
 

src/main/java/io/milvus/exception/ParamException.java

@@ -1,6 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.exception;
 
-public class ParamException extends RuntimeException{
+public class ParamException extends RuntimeException {
     private String msg;
     private Integer status;
 
@@ -9,14 +28,11 @@ public class ParamException extends RuntimeException{
         this.status = -1;
     }
 
-
     public ParamException(String msg, Integer status) {
         this.msg = msg;
         this.status = status;
     }
 
-
-
     public String getMsg() {
         return msg;
     }

src/main/java/io/milvus/param/ConnectParam.java

@@ -23,129 +23,130 @@ import javax.annotation.Nonnull;
 import java.util.concurrent.TimeUnit;
 
 /**
- * coonectParam, timeUnit:ms
+ * connectParam, timeUnit:ms
  */
 public class ConnectParam {
-  private final String host;
-  private final int port;
-  private final long connectTimeoutMs;
-  private final long keepAliveTimeMs;
-  private final long keepAliveTimeoutMs;
-  private final boolean keepAliveWithoutCalls;
-  private final long idleTimeoutMs;
-
-  private ConnectParam(@Nonnull Builder builder) {
-    this.host = builder.host;
-    this.port = builder.port;
-    this.connectTimeoutMs = builder.connectTimeoutMs;
-    this.keepAliveTimeMs = builder.keepAliveTimeMs;
-    this.keepAliveTimeoutMs = builder.keepAliveTimeoutMs;
-    this.keepAliveWithoutCalls = builder.keepAliveWithoutCalls;
-    this.idleTimeoutMs = builder.idleTimeoutMs;
-  }
-
-  public String getHost() {
-    return host;
-  }
-
-  public int getPort() {
-    return port;
-  }
-
-  public long getConnectTimeoutMs() {
-    return connectTimeoutMs;
-  }
-
-  public long getKeepAliveTimeMs() {
-    return keepAliveTimeMs;
-  }
-
-  public long getKeepAliveTimeoutMs() {
-    return keepAliveTimeoutMs;
-  }
-
-  public boolean isKeepAliveWithoutCalls() {
-    return keepAliveWithoutCalls;
-  }
-
-  public long getIdleTimeoutMs() {
-    return idleTimeoutMs;
-  }
-
-  /** Builder for <code>ConnectParam</code> */
-  public static class Builder {
-    private String host = "localhost";
-    private int port = 19530;
-    private long connectTimeoutMs = 10000;
-    private long keepAliveTimeMs = Long.MAX_VALUE; // Disabling keepalive
-    private long keepAliveTimeoutMs = 20000;
-    private boolean keepAliveWithoutCalls = false;
-    private long idleTimeoutMs = TimeUnit.MILLISECONDS.convert(24, TimeUnit.HOURS);
-
-    private Builder(){}
-
-    public static Builder newBuilder(){
-      return new Builder();
+    private final String host;
+    private final int port;
+    private final long connectTimeoutMs;
+    private final long keepAliveTimeMs;
+    private final long keepAliveTimeoutMs;
+    private final boolean keepAliveWithoutCalls;
+    private final long idleTimeoutMs;
+
+    private ConnectParam(@Nonnull Builder builder) {
+        this.host = builder.host;
+        this.port = builder.port;
+        this.connectTimeoutMs = builder.connectTimeoutMs;
+        this.keepAliveTimeMs = builder.keepAliveTimeMs;
+        this.keepAliveTimeoutMs = builder.keepAliveTimeoutMs;
+        this.keepAliveWithoutCalls = builder.keepAliveWithoutCalls;
+        this.idleTimeoutMs = builder.idleTimeoutMs;
     }
 
-    public Builder withHost(@Nonnull String host) {
-      this.host = host;
-      return this;
+    public String getHost() {
+        return host;
     }
 
-    public Builder withPort(int port) throws IllegalArgumentException {
-      if (port < 0 || port > 0xFFFF) {
-        throw new IllegalArgumentException("Port is out of range!");
-      }
-      this.port = port;
-      return this;
+    public int getPort() {
+        return port;
     }
 
-    public Builder withConnectTimeout(long connectTimeout, @Nonnull TimeUnit timeUnit)
-        throws IllegalArgumentException {
-      if (connectTimeout <= 0L) {
-        throw new IllegalArgumentException("Connect timeout must be positive!");
-      }
-      this.connectTimeoutMs = timeUnit.toMillis(connectTimeout);
-      return this;
+    public long getConnectTimeoutMs() {
+        return connectTimeoutMs;
     }
 
-    public Builder withKeepAliveTime(long keepAliveTime, @Nonnull TimeUnit timeUnit)
-        throws IllegalArgumentException {
-      if (keepAliveTime <= 0L) {
-        throw new IllegalArgumentException("Keepalive time must be positive!");
-      }
-      this.keepAliveTimeMs = timeUnit.toMillis(keepAliveTime);
-      return this;
+    public long getKeepAliveTimeMs() {
+        return keepAliveTimeMs;
     }
 
-    public Builder withKeepAliveTimeout(long keepAliveTimeout, @Nonnull TimeUnit timeUnit)
-        throws IllegalArgumentException {
-      if (keepAliveTimeout <= 0L) {
-        throw new IllegalArgumentException("Keepalive timeout must be positive!");
-      }
-      this.keepAliveTimeoutMs = timeUnit.toNanos(keepAliveTimeout);
-      return this;
+    public long getKeepAliveTimeoutMs() {
+        return keepAliveTimeoutMs;
     }
 
-
-    public Builder keepAliveWithoutCalls(boolean enable) {
-      keepAliveWithoutCalls = enable;
-      return this;
+    public boolean isKeepAliveWithoutCalls() {
+        return keepAliveWithoutCalls;
     }
 
-
-    public Builder withIdleTimeout(long idleTimeout, @Nonnull TimeUnit timeUnit)
-        throws IllegalArgumentException {
-      if (idleTimeout <= 0L) {
-        throw new IllegalArgumentException("Idle timeout must be positive!");
-      }
-      this.idleTimeoutMs = timeUnit.toMillis(idleTimeout);
-      return this;
+    public long getIdleTimeoutMs() {
+        return idleTimeoutMs;
     }
 
-    public ConnectParam build() {
-      return new ConnectParam(this);
+    /**
+     * Builder for <code>ConnectParam</code>
+     */
+    public static class Builder {
+        private String host = "localhost";
+        private int port = 19530;
+        private long connectTimeoutMs = 10000;
+        private long keepAliveTimeMs = Long.MAX_VALUE; // Disabling keepalive
+        private long keepAliveTimeoutMs = 20000;
+        private boolean keepAliveWithoutCalls = false;
+        private long idleTimeoutMs = TimeUnit.MILLISECONDS.convert(24, TimeUnit.HOURS);
+
+        private Builder() {
+        }
+
+        public static Builder newBuilder() {
+            return new Builder();
+        }
+
+        public Builder withHost(@Nonnull String host) {
+            this.host = host;
+            return this;
+        }
+
+        public Builder withPort(int port) throws IllegalArgumentException {
+            if (port < 0 || port > 0xFFFF) {
+                throw new IllegalArgumentException("Port is out of range!");
+            }
+            this.port = port;
+            return this;
+        }
+
+        public Builder withConnectTimeout(long connectTimeout, @Nonnull TimeUnit timeUnit)
+                throws IllegalArgumentException {
+            if (connectTimeout <= 0L) {
+                throw new IllegalArgumentException("Connect timeout must be positive!");
+            }
+            this.connectTimeoutMs = timeUnit.toMillis(connectTimeout);
+            return this;
+        }
+
+        public Builder withKeepAliveTime(long keepAliveTime, @Nonnull TimeUnit timeUnit)
+                throws IllegalArgumentException {
+            if (keepAliveTime <= 0L) {
+                throw new IllegalArgumentException("Keepalive time must be positive!");
+            }
+            this.keepAliveTimeMs = timeUnit.toMillis(keepAliveTime);
+            return this;
+        }
+
+        public Builder withKeepAliveTimeout(long keepAliveTimeout, @Nonnull TimeUnit timeUnit)
+                throws IllegalArgumentException {
+            if (keepAliveTimeout <= 0L) {
+                throw new IllegalArgumentException("Keepalive timeout must be positive!");
+            }
+            this.keepAliveTimeoutMs = timeUnit.toNanos(keepAliveTimeout);
+            return this;
+        }
+
+        public Builder keepAliveWithoutCalls(boolean enable) {
+            keepAliveWithoutCalls = enable;
+            return this;
+        }
+
+        public Builder withIdleTimeout(long idleTimeout, @Nonnull TimeUnit timeUnit)
+                throws IllegalArgumentException {
+            if (idleTimeout <= 0L) {
+                throw new IllegalArgumentException("Idle timeout must be positive!");
+            }
+            this.idleTimeoutMs = timeUnit.toMillis(idleTimeout);
+            return this;
+        }
+
+        public ConnectParam build() {
+            return new ConnectParam(this);
+        }
     }
-  }
 }

src/main/java/io/milvus/param/Constant.java

@@ -1,12 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param;
 
 public class Constant {
-
     // default value for search key
-    public static String vectorTag = "$0";
-    public static String vectorFiled = "anns_field";
-    public static String topK = "topk";
-    public static String metricType = "metric_type";
-    public static String parmas = "params";
-
+    public static final String VECTOR_TAG = "$0";
+    public static final String VECTOR_FIELD = "anns_field";
+    public static final String TOP_K = "topk";
+    public static final String METRIC_TYPE = "metric_type";
+    public static final String PARAMS = "params";
 }

src/main/java/io/milvus/param/MetricType.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param;
 
 public enum MetricType {
@@ -11,5 +30,4 @@ public enum MetricType {
     SUBSTRUCTURE,
     SUPERSTRUCTURE,
     ;
-
 }

src/main/java/io/milvus/param/R.java

@@ -1,6 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param;
 
 import io.milvus.grpc.ErrorCode;
+
 import java.util.Arrays;
 import java.util.Optional;
 
@@ -33,8 +53,7 @@ public class R<T> {
         this.data = data;
     }
 
-;
-    public static <T> R<T> failed(Exception exception){
+    public static <T> R<T> failed(Exception exception) {
         R<T> r = new R<>();
         r.setStatus(Status.Unknown.getCode());
         r.setException(exception);
@@ -48,28 +67,30 @@ public class R<T> {
         return r;
     }
 
-    public static <T> R<T> failed(Status statusCode){
+    public static <T> R<T> failed(Status statusCode) {
         R<T> r = new R<>();
         r.setStatus(statusCode.getCode());
         r.setException(new Exception(statusCode.name()));
         return r;
     }
 
-    public static <T> R<T> success(){
+    public static <T> R<T> success() {
         R<T> r = new R<>();
         r.setStatus(Status.Success.getCode());
         return r;
     }
 
 
-    public static <T> R<T> success(T data){
+    public static <T> R<T> success(T data) {
         R<T> r = new R<>();
         r.setStatus(Status.Success.getCode());
         r.setData(data);
         return r;
     }
 
-    /** Represents server and client side status code */
+    /**
+     * Represents server and client side status code
+     */
     public enum Status {
         // Server side error
         Success(0),
@@ -128,18 +149,17 @@ public class R<T> {
 
     @Override
     public String toString() {
-        if(exception != null){
+        if (exception != null) {
             return "R{" +
                     "exception=" + exception.getMessage() +
                     ", status=" + status +
                     ", data=" + data +
                     '}';
-        }else{
+        } else {
             return "R{" +
                     "status=" + status +
                     ", data=" + data +
                     '}';
         }
-
     }
 }

src/main/java/io/milvus/param/collection/FieldType.java

@@ -16,8 +16,8 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package io.milvus.param.collection;
 
+package io.milvus.param.collection;
 
 import io.milvus.grpc.DataType;
 

src/main/java/io/milvus/param/dml/CalcDistanceParam.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param.dml;
 
 import io.milvus.exception.ParamException;
@@ -14,8 +33,10 @@ public class CalcDistanceParam {
     private final List<Float> vector2;
     private final MetricType metricType;
 
-    public CalcDistanceParam(@Nonnull List<Float> vector1,@Nonnull List<Float> vector2,@Nonnull MetricType metricType){
-        if (vector1.size() != vector2.size()){
+    public CalcDistanceParam(@Nonnull List<Float> vector1,
+                             @Nonnull List<Float> vector2,
+                             @Nonnull MetricType metricType) {
+        if (vector1.size() != vector2.size()) {
             throw new ParamException("size is not equal");
         }
 

src/main/java/io/milvus/param/dml/DeleteParam.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param.dml;
 
 import javax.annotation.Nonnull;
@@ -28,12 +47,12 @@ public class DeleteParam {
     public static class Builder {
         private String dbName = "";
         private String collectionName;
-        private String partitionName ;
+        private String partitionName;
 
         private Builder() {
         }
 
-        public static Builder nweBuilder() {
+        public static Builder newBuilder() {
             return new Builder();
         }
 
@@ -42,12 +61,12 @@ public class DeleteParam {
             return this;
         }
 
-        public Builder setDbName(@Nonnull String dbName){
+        public Builder setDbName(@Nonnull String dbName) {
             this.dbName = dbName;
             return this;
         }
 
-        public Builder setCollectionName(@Nonnull String collectionName){
+        public Builder setCollectionName(@Nonnull String collectionName) {
             this.collectionName = collectionName;
             return this;
         }
@@ -55,6 +74,5 @@ public class DeleteParam {
         public DeleteParam build() {
             return new DeleteParam(this);
         }
-
     }
 }

src/main/java/io/milvus/param/dml/InsertParam.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param.dml;
 
 import io.milvus.grpc.DataType;
@@ -8,8 +27,8 @@ import java.util.List;
 /**
  * fieldNames,dataTypes, fieldValues' order must be consistent.
  * explain fieldValues:
- *    if dataType is scalar: ? is basic type, like Integer,Long...
- *    if dataType is FloatVector: ? is List<Float>
+ *     if dataType is scalar: ? is basic type, like Integer,Long...
+ *     if dataType is FloatVector: ? is List<Float>
  */
 public class InsertParam {
     private final String collectionName;
@@ -68,7 +87,7 @@ public class InsertParam {
             this.collectionName = collectionName;
         }
 
-        public static Builder nweBuilder(@Nonnull String collectionName) {
+        public static Builder newBuilder(@Nonnull String collectionName) {
             return new Builder(collectionName);
         }
 
@@ -100,6 +119,5 @@ public class InsertParam {
         public InsertParam build() {
             return new InsertParam(this);
         }
-
     }
 }

src/main/java/io/milvus/param/dml/QueryParam.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param.dml;
 
 import com.google.common.collect.Lists;
@@ -13,7 +32,7 @@ public class QueryParam {
     private final List<String> outFields;
     private final String expr;
 
-    private QueryParam(@Nonnull Builder builder){
+    private QueryParam(@Nonnull Builder builder) {
         this.dbName = builder.dbName;
         this.collectionName = builder.collectionName;
         this.partitionNames = builder.partitionNames;
@@ -41,32 +60,32 @@ public class QueryParam {
         return expr;
     }
 
-    public static class Builder{
+    public static class Builder {
         private String dbName = "";
         private String collectionName;
         private List<String> partitionNames = Lists.newArrayList();
         private List<String> outFields = new ArrayList<>();
         private String expr;
 
-        private Builder(@Nonnull String expr){
+        private Builder(@Nonnull String expr) {
             this.expr = expr;
         }
 
-        public static Builder newBuilder(@Nonnull String expr){
+        public static Builder newBuilder(@Nonnull String expr) {
             return new Builder(expr);
         }
 
-        public Builder setDbName(@Nonnull String dbName){
+        public Builder setDbName(@Nonnull String dbName) {
             this.dbName = dbName;
             return this;
         }
 
-        public Builder setCollectionName(@Nonnull String collectionName){
+        public Builder setCollectionName(@Nonnull String collectionName) {
             this.collectionName = collectionName;
             return this;
         }
 
-        public Builder setPartitionNames(@Nonnull List<String> partitionNames){
+        public Builder setPartitionNames(@Nonnull List<String> partitionNames) {
             this.partitionNames = partitionNames;
             return this;
         }
@@ -81,9 +100,8 @@ public class QueryParam {
             return this;
         }
 
-        public QueryParam build(){
+        public QueryParam build() {
             return new QueryParam(this);
         }
     }
-
 }

src/main/java/io/milvus/param/dml/SearchParam.java

@@ -1,3 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package io.milvus.param.dml;
 
 import com.google.common.collect.Lists;
@@ -21,9 +40,9 @@ public class SearchParam {
     private final String dsl;
     private final List<String> outFields;
     private final List<List<Float>> vectors;
-    private final Map<String,String> params;
+    private final Map<String, String> params;
 
-    private SearchParam(@Nonnull Builder builder){
+    private SearchParam(@Nonnull Builder builder) {
         this.dbName = builder.dbName;
         this.collectionName = builder.collectionName;
         this.partitionNames = builder.partitionNames;
@@ -81,7 +100,7 @@ public class SearchParam {
         return params;
     }
 
-    public static class Builder{
+    public static class Builder {
         private String dbName = "";
         private String collectionName;
         private List<String> partitionNames = Lists.newArrayList();
@@ -92,26 +111,26 @@ public class SearchParam {
         private String dsl;
         private List<String> outFields = new ArrayList<>();
         private List<List<Float>> vectors;
-        private Map<String,String> params = new HashMap<>();
+        private Map<String, String> params = new HashMap<>();
 
-        private Builder(){
+        private Builder() {
         }
 
-        public static Builder newBuilder(){
+        public static Builder newBuilder() {
             return new Builder();
         }
 
-        public Builder setDbName(@Nonnull String dbName){
+        public Builder setDbName(@Nonnull String dbName) {
             this.dbName = dbName;
             return this;
         }
 
-        public Builder setCollectionName(@Nonnull String collectionName){
+        public Builder setCollectionName(@Nonnull String collectionName) {
             this.collectionName = collectionName;
             return this;
         }
 
-        public Builder setPartitionNames(@Nonnull List<String> partitionNames){
+        public Builder setPartitionNames(@Nonnull List<String> partitionNames) {
             this.partitionNames = partitionNames;
             return this;
         }
@@ -157,9 +176,8 @@ public class SearchParam {
             return this;
         }
 
-        public SearchParam build(){
+        public SearchParam build() {
             return new SearchParam(this);
         }
     }
-
 }

src/main/java/io/milvus/param/index/CreateIndexParam.java

@@ -27,7 +27,7 @@ import java.util.Map;
 public class CreateIndexParam {
     private final String collectionName;
     private final String fieldName;
-    private final Map<String,String> extraParam;
+    private final Map<String, String> extraParam;
 
     public String getCollectionName() {
         return collectionName;
@@ -37,11 +37,10 @@ public class CreateIndexParam {
         return fieldName;
     }
 
-    public Map<String,String> getExtraParam() {
+    public Map<String, String> getExtraParam() {
         return extraParam;
     }
 
-
     public CreateIndexParam(Builder builder) {
         this.collectionName = builder.collectionName;
         this.fieldName = builder.fieldName;
@@ -51,7 +50,7 @@ public class CreateIndexParam {
     public static final class Builder {
         private String collectionName;
         private String fieldName;
-        private Map<String,String> extraParam;
+        private Map<String, String> extraParam;
 
         private Builder() {
         }
@@ -70,7 +69,7 @@ public class CreateIndexParam {
             return this;
         }
 
-        public Builder withExtraParam(Map<String,String> extraParam) {
+        public Builder withExtraParam(Map<String, String> extraParam) {
             this.extraParam = extraParam;
             return this;
         }