MCPcopy Index your code
hub / github.com/questdb/questdb / setupViewJobs

Method setupViewJobs

core/src/main/java/io/questdb/ServerMain.java:548–555  ·  view source on GitHub ↗
(WorkerPool vWorkerPool, CairoEngine engine, int sharedQueryWorkerCount)

Source from the content-addressed store, hash-verified

546 }
547
548 protected void setupViewJobs(WorkerPool vWorkerPool, CairoEngine engine, int sharedQueryWorkerCount) {
549 for (int i = 0, workerCount = vWorkerPool.getWorkerCount(); i < workerCount; i++) {
550 // create job per worker
551 final ViewCompilerJob viewCompilerJob = new ViewCompilerJob(i, engine, sharedQueryWorkerCount);
552 vWorkerPool.assign(i, viewCompilerJob);
553 vWorkerPool.freeOnExit(viewCompilerJob);
554 }
555 }
556
557 protected void setupWalApplyJob(
558 WorkerPool sharedPoolWrite,

Callers 1

setupDedicatedPoolsMethod · 0.95

Calls 3

getWorkerCountMethod · 0.65
assignMethod · 0.45
freeOnExitMethod · 0.45

Tested by

no test coverage detected