Class ExtractViaBasepullQueryStep

java.lang.Object

com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractExtractStep

com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.ExtractViaQueryStep

com.kingsrook.qqq.backend.core.processes.implementations.basepull.ExtractViaBasepullQueryStep

All Implemented Interfaces:

BackendStep, BasepullExtractStepInterface

public class ExtractViaBasepullQueryStep
extends ExtractViaQueryStep
implements BasepullExtractStepInterface

Version of ExtractViaQueryStep that knows how to set up a basepull query.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	SECONDS_TO_SUBTRACT_FROM_LAST_RUN_TIME_KEY
protected static final String	SECONDS_TO_SUBTRACT_FROM_THIS_RUN_TIME_KEY

Fields inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.ExtractViaQueryStep

FIELD_SOURCE_TABLE

Constructor Summary

Constructors

Constructor	Description
ExtractViaBasepullQueryStep()

Method Summary

Modifier and Type	Method	Description
protected String	getLastRunTimeString(RunBackendStepInput runBackendStepInput)
protected QQueryFilter	getQueryFilter(RunBackendStepInput runBackendStepInput)
protected String	getThisRunTimeString(RunBackendStepInput runBackendStepInput)
protected boolean	willTheBasePullQueryBeUsed(RunBackendStepInput runBackendStepInput)	Let a subclass know if getQueryFilter will use the "default filter" (e.g., from our base class, which would come from values passed in to the process), or if the BasePull Query would be used (e.g., for a scheduled job).

Methods inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.ExtractViaQueryStep

createRecordPipe, customizeInputPreQuery, doCount, preRun, run

Methods inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractExtractStep

getLimit, getRecordPipe, setLimit, setRecordPipe

Methods inherited from class java.lang.Object

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

Field Details

SECONDS_TO_SUBTRACT_FROM_THIS_RUN_TIME_KEY

protected static final String SECONDS_TO_SUBTRACT_FROM_THIS_RUN_TIME_KEY

See Also:

• Constant Field Values

SECONDS_TO_SUBTRACT_FROM_LAST_RUN_TIME_KEY

protected static final String SECONDS_TO_SUBTRACT_FROM_LAST_RUN_TIME_KEY

See Also:

• Constant Field Values

Constructor Details

ExtractViaBasepullQueryStep

public ExtractViaBasepullQueryStep()

Method Details

getQueryFilter

protected QQueryFilter getQueryFilter(RunBackendStepInput runBackendStepInput)
                               throws QException

Overrides:

getQueryFilter in class ExtractViaQueryStep

Throws:

QException

willTheBasePullQueryBeUsed

protected boolean willTheBasePullQueryBeUsed(RunBackendStepInput runBackendStepInput)

Let a subclass know if getQueryFilter will use the "default filter" (e.g., from our base class, which would come from values passed in to the process), or if the BasePull Query would be used (e.g., for a scheduled job).

getLastRunTimeString

protected String getLastRunTimeString(RunBackendStepInput runBackendStepInput)
                               throws QException

Throws:

QException

getThisRunTimeString

protected String getThisRunTimeString(RunBackendStepInput runBackendStepInput)
                               throws QException

Throws:

QException