appendRow()

This operation appends a row of data to the LocalBulkWriter buffer. The data will be written to a file when the buffer is full or when commit() is called.

public void appendRow(JsonObject rowData) throws IOException, InterruptedException

PARAMETERS:

• rowData (JsonObject) -

  A JSON object representing a single row of data.

RETURNS:

void

EXCEPTIONS:

• MilvusClientException

  This exception will be raised when any error occurs during this operation.

Example

LocalBulkWriter writer = new LocalBulkWriter(config);
JsonObject row = new JsonObject();
row.addProperty("id", 1L);
row.add("vector", gson.toJsonTree(new float[]{0.1f, 0.2f, 0.3f}));
writer.appendRow(row);