Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 7 additions & 1 deletion sdk-core/src/main/java/io/milvus/client/MilvusClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -45,10 +45,16 @@

import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
* The Milvus Client Interface
*/
public interface MilvusClient {

Logger logger = LoggerFactory.getLogger(MilvusClient.class);

/**
* Timeout setting for rpc call.
*
Expand Down Expand Up @@ -99,7 +105,7 @@ default void close() {
try {
close(TimeUnit.MINUTES.toSeconds(1));
} catch (InterruptedException e) {
System.out.println("Interrupted during shutdown Milvus client!");
logger.error("Interrupted during shutdown Milvus client!");
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,6 @@ private void setUpRangeParameters(List<QueryResultsWrapper.RowRecord> page) {
tailBand = getDistance(lastHit);
String msg = String.format("set up init parameter for searchIterator width:%s tail_band:%s", width, tailBand);
logger.debug(msg);
// System.out.println(msg);
}

private void updateFilteredIds(SearchResultsWrapper searchResultsWrapper) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1044,7 +1044,7 @@ public void close() {
try {
close(TimeUnit.MINUTES.toSeconds(1));
} catch (InterruptedException e) {
System.out.println("Interrupted during shutdown Milvus client!");
logger.error("Interrupted during shutdown Milvus client!");
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -481,7 +481,7 @@ private void WaitForLoadCollection(MilvusServiceGrpc.MilvusServiceBlockingStub b
Thread.sleep(500); // Sleep for 0.5 second. Adjust this value as needed.
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.out.println("Thread was interrupted, Failed to complete operation");
logger.error("Thread was interrupted, Failed to complete operation");
return; // or handle interruption appropriately
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -249,7 +249,7 @@ private void WaitForIndexComplete(MilvusServiceGrpc.MilvusServiceBlockingStub bl
Thread.sleep(500); // Sleep for 0.5 second. Adjust this value as needed.
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.out.println("Thread was interrupted, failed to complete operation");
logger.error("Thread was interrupted, failed to complete operation");
return; // or handle interruption appropriately
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -152,7 +152,7 @@ private void WaitForLoadPartitions(MilvusServiceGrpc.MilvusServiceBlockingStub b
Thread.sleep(500); // Sleep for 0.5 second. Adjust this value as needed.
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.out.println("Thread was interrupted, failed to complete operation");
logger.error("Thread was interrupted, failed to complete operation");
return; // or handle interruption appropriately
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -372,7 +372,7 @@ public RunAnalyzerResp runAnalyzer(MilvusServiceGrpc.MilvusServiceBlockingStub b
builder.addAllAnalyzerNames(analyzerNames);

String params = JsonUtils.toJson(request.getAnalyzerParams());
System.out.println(params);
logger.debug(params);
RunAnalyzerRequest runRequest = builder.addAllPlaceholder(byteStrings)
.setAnalyzerParams(params)
.setWithDetail(request.getWithDetail())
Expand Down
Loading