bulkImport()
This operation imports the prepared data files to Milvus. To learn how to prepare your data files, read Prepare Source Data.
public static String bulkImport(String url, BaseImportRequest request)
Request Syntax
bulkImport.bulkImport(
url,
request
)
PARAMETERS:
url (String) -
The endpoint of the connected Milvus instance.
request (BaseImportRequest) -
A BaseImportRequest instance.
RETURN TYPE:
String
RETURNS:
The ID of the created import job.
BaseImportRequest
A BaseImportRequest instance is implemented in MilvusImportRequest.
MilvusImportRequest
MilvusImportRequest.builder()
.dbName(String dbName)
.collectionName(String collectionName)
.partitionName(String partitionName)
.files(List<List<String>> files)
.build()
BUILDER METHODS:
dbName(String dbName)
The name of the target database. The value of this parameter defaults to
default
.collectionName(String collectionName)
The name of a collection in the target cluster of this operation.
partitionName(String partitionName)
The name of the partition in the target cluster of this operation. The value defaults to
default
.files(List<List<String>> files)
The list of string lists, each string list contains a singular row-based file path or multiple column-based file paths.
Example
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import io.milvus.bulkwriter.BulkImport;
import io.milvus.bulkwriter.request.import_.MilvusImportRequest;
List<List<String>> batchFiles = new ArrayList<>();
batchFiles.add(Collections.singletonList("bulk_data/1.parquet"));
batchFiles.add(Collections.singletonList("bulk_data/2.parquet"));
MilvusImportRequest milvusImportRequest = MilvusImportRequest.builder()
.collectionName(collectionName)
.files(batchFiles)
.build();
String bulkImportResult = BulkImport.bulkImport(url, milvusImportRequest);
Gson GSON_INSTANCE = new Gson()
JsonObject result = GSON_INSTANCE.fromJson(bulkImportResult, JsonObject.class);
String jobId = result.getAsJsonObject("data").get("jobId").getAsString();
System.out.println("Create a bulkInert task, job id: " + jobId);