Class BulkInsertStepUtils

java.lang.Object

com.kingsrook.qqq.backend.core.processes.implementations.bulk.insert.BulkInsertStepUtils

public class BulkInsertStepUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
BulkInsertStepUtils()

Method Summary

Modifier and Type	Method	Description
static BulkLoadProfile	getBulkLoadProfile(RunBackendStepInput runBackendStepInput)
static ProcessTracerKeyRecordMessage	getProcessTracerKeyRecordMessage(RunBackendStepInput runBackendStepInput)
static StorageInput	getStorageInputForTheFile(RunBackendStepInput input)
static QRecord	handleSavedBulkLoadProfileIdValue(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput)
static boolean	isHeadless(RunBackendStepInput runBackendStepInput)
static void	setHeadless(RunProcessInput runProcessInput)
static void	setNextStepPrepareValueMapping(RunBackendStepOutput runBackendStepOutput)
static void	setNextStepStreamedETLPreview(RunBackendStepOutput runBackendStepOutput)
static void	setProcessTracerKeyRecordMessage(RunProcessInput runProcessInput, ProcessTracerKeyRecordMessage processTracerKeyRecordMessage)
static void	setStorageInputForTheFile(RunProcessInput runProcessInput, StorageInput storageInput)

Methods inherited from class java.lang.Object

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

Constructor Details

BulkInsertStepUtils

public BulkInsertStepUtils()

Method Details

getStorageInputForTheFile

public static StorageInput getStorageInputForTheFile(RunBackendStepInput input)
                                              throws QException

Throws:

QException

setStorageInputForTheFile

public static void setStorageInputForTheFile(RunProcessInput runProcessInput,
 StorageInput storageInput)

setNextStepStreamedETLPreview

public static void setNextStepStreamedETLPreview(RunBackendStepOutput runBackendStepOutput)

setNextStepPrepareValueMapping

public static void setNextStepPrepareValueMapping(RunBackendStepOutput runBackendStepOutput)

getBulkLoadProfile

public static BulkLoadProfile getBulkLoadProfile(RunBackendStepInput runBackendStepInput)

handleSavedBulkLoadProfileIdValue

public static QRecord handleSavedBulkLoadProfileIdValue(RunBackendStepInput runBackendStepInput,
 RunBackendStepOutput runBackendStepOutput)
                                                 throws QException

Throws:

QException

isHeadless

public static boolean isHeadless(RunBackendStepInput runBackendStepInput)

setHeadless

public static void setHeadless(RunProcessInput runProcessInput)

setProcessTracerKeyRecordMessage

public static void setProcessTracerKeyRecordMessage(RunProcessInput runProcessInput,
 ProcessTracerKeyRecordMessage processTracerKeyRecordMessage)

getProcessTracerKeyRecordMessage

public static ProcessTracerKeyRecordMessage getProcessTracerKeyRecordMessage(RunBackendStepInput runBackendStepInput)