MCPcopy Create free account
hub / github.com/crate/crate / executeBulk

Method executeBulk

server/src/test/java/io/crate/session/SessionTest.java:321–332  ·  view source on GitHub ↗
(DependencyCarrier executor,
                                                                       PlannerContext plannerContext,
                                                                       List<Row> bulkParams,
                                                                       SubQueryResults subQueryResults)

Source from the content-addressed store, hash-verified

319 }
320
321 @Override
322 public CompletableFuture<BulkResponse> executeBulk(DependencyCarrier executor,
323 PlannerContext plannerContext,
324 List<Row> bulkParams,
325 SubQueryResults subQueryResults) {
326 // Do another execution to overwrite `mostRecentJobID`
327 session.quickExec("SELECT 1", new BaseResultReceiver(), null);
328 var response = new BulkResponse(2);
329 response.update(0, 1L, null);
330 response.update(1, 1L, null);
331 return completedFuture(response);
332 }
333 }
334 );
335

Callers

nothing calls this directly

Calls 2

updateMethod · 0.95
quickExecMethod · 0.80

Tested by

no test coverage detected