Class DurableJobDiversion

java.lang.Object

com.kingsrook.qqq.backend.core.jobs.DurableJobDiversion

public final class DurableJobDiversion
extends Object

"Automatically" (spec section 2.4): when an eligible streamed ETL process reaches its execute step with more rows than durableThresholdRows (default 1,000), or is alwaysDurable, the execute step is not run inline: the process is launched as a durable job with the values collected so far, and the step returns at once with the value durableJobId and a summary line that says the work is running in the background. Clients link to the job. Never inside a job (a chunk runs the same process steps), and never for the system user. A process value durableRunInline=true keeps the old inline behaviour for one run.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	VALUE_DURABLE_JOB_ID
static final String	VALUE_RUN_INLINE

Method Summary

Modifier and Type	Method	Description
static Optional<RunBackendStepOutput>	maybeDivert(RunBackendStepInput input, QProcessMetaData process, QBackendStepMetaData step)	If this backend step should become a durable job, launch it and return the step's output; else empty (run the step as usual).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

VALUE_DURABLE_JOB_ID

public static final String VALUE_DURABLE_JOB_ID

See Also:

• Constant Field Values

VALUE_RUN_INLINE

public static final String VALUE_RUN_INLINE

See Also:

• Constant Field Values

Method Details

maybeDivert

public static Optional<RunBackendStepOutput> maybeDivert(RunBackendStepInput input,
 QProcessMetaData process,
 QBackendStepMetaData step)
                                                  throws QException

If this backend step should become a durable job, launch it and return the step's output; else empty (run the step as usual).

Throws:

QException