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

Method exec

server/src/main/java/io/crate/session/Session.java:708–715  ·  view source on GitHub ↗
(List<DeferredExecution> executions, boolean forceBulk)

Source from the content-addressed store, hash-verified

706 }
707
708 private CompletableFuture<?> exec(List<DeferredExecution> executions, boolean forceBulk) {
709 if (executions.size() == 1 && !forceBulk) {
710 var toExec = executions.get(0);
711 return singleExec(toExec.portal(), toExec.resultReceiver(), toExec.maxRows());
712 } else {
713 return bulkExec(executions);
714 }
715 }
716
717 private CompletableFuture<?> bulkExec(List<DeferredExecution> toExec) {
718 assert !toExec.isEmpty() : "Must have at least 1 deferred execution for bulk exec";

Callers 1

Calls 7

singleExecMethod · 0.95
bulkExecMethod · 0.95
portalMethod · 0.80
resultReceiverMethod · 0.80
maxRowsMethod · 0.80
sizeMethod · 0.65
getMethod · 0.65

Tested by

no test coverage detected