Uses of Class
com.toolsverse.etl.core.config.EtlConfig

Packages that use EtlConfig

Package	Description
com.toolsverse.etl.core.codegen
com.toolsverse.etl.core.engine
com.toolsverse.etl.core.task.common
com.toolsverse.etl.core.task.informix
com.toolsverse.etl.core.task.oracle
com.toolsverse.etl.core.task.redshift
com.toolsverse.etl.core.task.snowflake
com.toolsverse.etl.core.task.sqlserver
com.toolsverse.etl.core.util

Uses of EtlConfig in com.toolsverse.etl.core.codegen

Methods in com.toolsverse.etl.core.codegen with parameters of type EtlConfig

Modifier and Type	Method and Description
void	DefaultCodeGen.assembleCode(EtlConfig config, Scenario scenario, Driver driver, int loadIndex, boolean silent)
void	DefaultCodeGen.cleanUp(EtlConfig config, Scenario scenario, Driver driver, Connection conn)
void	DefaultCodeGen.cleanUpOnException(EtlConfig config, Scenario scenario, Driver driver, Connection cleanUpConn)
void	DefaultCodeGen.execute(EtlConfig config, Scenario scenario, Driver driver, boolean silent, Connection conn, Connection cleanUpConn, Destination destination)
void	DefaultCodeGen.prepare(EtlConfig config, Scenario scenario, Destination destination, boolean silent, boolean onlyInit, boolean isStreaming)
void	DefaultCodeGen.runRemainingBatch(EtlConfig config, Scenario scenario, Connection conn, Destination destination)

Uses of EtlConfig in com.toolsverse.etl.core.engine

Methods in com.toolsverse.etl.core.engine that return EtlConfig

Modifier and Type	Method and Description
EtlConfig	LoadFunctionContext.getConfig() Gets the etl config associated with the current etl process.
EtlConfig	EtlRequest.getEtlConfig() Gets the etl config.

Methods in com.toolsverse.etl.core.engine with parameters of type EtlConfig

Modifier and Type	Method and Description
void	CodeGen.assembleCode(EtlConfig config, Scenario scenario, Driver driver, int loadIndex, boolean silent) Assembles prepared code.
void	CodeGen.cleanUp(EtlConfig config, Scenario scenario, Driver driver, Connection conn) Clean up after last block of code is executed.
void	CodeGen.cleanUpOnException(EtlConfig config, Scenario scenario, Driver driver, Connection cleanUpConn) Clean up database objects on exception.
void	MetadataTracker.createTableAndIndexesOrChangeFieldDataTypeIfNeeded(Scenario scenario, EtlConfig config, Destination destination, DataSet dataSet, Alias alias, CodeGen codeGen) Creates the table and indexes or change field data type if needed.
EtlResponse	EtlProcess.execute(EtlConfig config) Executes process using given etl config.
void	CodeGen.execute(EtlConfig config, Scenario scenario, Driver driver, boolean silent, Connection conn, Connection cleanUpConn, Destination destination) Executes code.
void	EtlProcess.execute(Scenario scenario, EtlConfig config, int index, TransactionMonitor transactionMonitor) Executes etl scenario.
TaskResult	OnTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario) Executes task before etl process is started.
TaskResult	TaskExecutor.executeBeforeEtlTasks(EtlConfig config, Block block, Scenario scenario) Executes PRE ETL tasks for the Block if any exist.
TaskResult	OnTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario) Executes task for each row of the data set.
TaskResult	TaskExecutor.executeInlineTasks(EtlConfig config, Block block, Scenario scenario, long index) Executes INLINE tasks for the Block if any exist.
TaskResult	TaskExecutor.executeOnExceptionTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) Executes ON_EXCEPTION tasks for the Block if any exist.
TaskResult	OnTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario) Executes task after extract or load finished.
TaskResult	TaskExecutor.executePostTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) Executes POST tasks for the Block if any exist.
TaskResult	OnTask.executePreTask(EtlConfig config, Task task, Scenario scenario) Executes task before extract or load started.
TaskResult	TaskExecutor.executePreTasks(EtlConfig config, Block block, Scenario scenario, DataSet dataSet) Executes PRE tasks for the Block if any exist.
void	Extractor.extract(EtlConfig config, Scenario scenario) Extracts data from all sources.
void	Extractor.extract(EtlConfig config, Scenario scenario, Loader loader, int index) Extracts data from all sources.
void	Extractor.extract(EtlConfig config, Scenario scenario, Source source, Destination destination, AddRecordCallback addRecordCallback) Extracts data from the source.
void	Extractor.extractMandatory(EtlConfig config, Scenario scenario) Extracts mandatory data sets.
Object	EtlMetricsTracker.getHighWatermark(EtlConfig config, Scenario scenario, Source source, Destination destination, Boolean... onLoad) Gets the high watermark value.
String	MetadataTracker.getLoadKey(EtlConfig config, Destination destination, String destTableName, List<String> fields, DataSetFields dataSetFields, Driver driver) Gets the load key.
Scenario	EtlFactory.getScenario(EtlConfig config, String fileName) Gets the scenario using PARSE_ALL_PARAM scope.
Scenario	EtlFactory.getScenario(EtlConfig config, String fileName, int parseScope) Gets the scenario.
String	MetadataTracker.getSourceKeys(Destination destination, EtlConfig config, DataSetFields dataSetFields) Gets the source keys.
boolean	Extractor.hasMixOfStreamAndNotStream(EtlConfig config, Scenario scenario) Checks if the scenario contains mix of stream and not stream transformations.
void	OnTask.init(EtlConfig config, Task task) Initializes task.
void	Loader.load(EtlConfig config, Scenario scenario, int loadIndex) Loads data for all destinations, if requested - in parallel threads.
static Object	Extractor.lookup(EtlConfig config, Scenario scenario, String connectionName, String name, String fieldName, String sql, TypedKeyValue<String,Object>... args) Extract data set, execute provided SQL statement and return the value of the provided field.This method is thread safe.
static DataSet	Extractor.lookup(EtlConfig config, Scenario scenario, String connectionName, String name, String sql, TypedKeyValue<String,Object>... args) Extract data set, and optionally execute provided SQL statement.
static Object	Extractor.lookupNoCache(EtlConfig config, Scenario scenario, String connectionName, String name, String fieldName, String sql, TypedKeyValue<String,Object>... args) Extract data set, execute provided SQL statement and return the value of the provided field.
static DataSet	Extractor.lookupNoCache(EtlConfig config, Scenario scenario, String connectionName, String name, String sql, TypedKeyValue<String,Object>... args) Extract data set, and optionally execute provided SQL statement.
void	EtlFactory.parseAfterTasks(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario) Parses "after" tasks.
void	EtlFactory.parseBeforeTasks(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario, String rootNodeName) Parses "before" tasks.
void	EtlFactory.parseDestinations(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario) Parses the destinations.
Scenario	EtlFactory.parseScenario(EtlConfig config, String code) Parses the scenario using PARSE_ALL_PARAM scope.
Scenario	EtlFactory.parseScenario(EtlConfig config, String code, int parseScope) Parses the scenario.
Scenario	EtlFactory.parseScenario(EtlConfig config, XmlUtils xml, int parseScope) Parses the scenario.
Scenario	EtlFactory.parseScenario(EtlConfig config, XmlUtils xml, int parseScope, org.w3c.dom.Node rootNode) Parses the scenario.
void	EtlFactory.parseScenarioVariables(XmlUtils xml, Scenario scenario, org.w3c.dom.Node rootNode, EtlConfig config) Parses the scenario variables.
void	EtlFactory.parseSources(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario) Parses the sources.
void	EtlFactory.parseTasks(EtlConfig config, XmlUtils xml, org.w3c.dom.Node rootNode, Scenario scenario, Block block, String rootNodeName) Parses tasks for the etl block.
void	CodeGen.prepare(EtlConfig config, Scenario scenario, Destination destination, boolean silent, boolean onlyInit, boolean isStreaming) Prepares code for the destination using given config and scenario.
TypedKeyValue<String,String>	EtlMetricsTracker.prepareTrackingExtract(Scenario scenario, Source source, Destination destination, String sql, EtlConfig config) Prepare tracking extract.
void	EtlProcess.printConfig(EtlConfig etlConfig) Prints the config.
boolean	MetadataTracker.recreateDestTableIfNeededWhenHWMIsEnabled(Scenario scenario, Source source, Destination destination, EtlConfig config) Recreate destination table if needed when the high watermark replication is enabled.
void	CodeGen.runRemainingBatch(EtlConfig config, Scenario scenario, Connection conn, Destination destination) Run remaining batch statements.
void	LoadFunctionContext.setConfig(EtlConfig value) Sets the etl config associated with the current etl process.
void	EtlRequest.setEtlConfig(EtlConfig value) Sets the etl config.
void	MetadataTracker.updateMetadataInTarget(EtlConfig config, Destination destination, DataSet dataSet, Scenario scenario) Update metadata in target.

Constructors in com.toolsverse.etl.core.engine with parameters of type EtlConfig

Constructor and Description
EtlRequest(EtlConfig config, List<Scenario> scenarios, int logLevel) Instantiates a new etl request.
EtlRequest(EtlConfig config, Scenario scenario, int logLevel) Instantiates a new etl request.

Uses of EtlConfig in com.toolsverse.etl.core.task.common

Methods in com.toolsverse.etl.core.task.common with parameters of type EtlConfig

Modifier and Type	Method and Description
static boolean	FileManagerTask.delete(EtlConfig config, String connectionName, String fileName) Delete file or resource.
TaskResult	FileManagerTask.execute(EtlConfig config, Task task, DataSet dataSet, Scenario scenario) Execute.
TaskResult	XslTransormTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Validator.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Union.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Transpose.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	SqlTask.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	SplitDataSet.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	ScriptTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	RemoveDuplicates.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	RegexpTransformator.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Populate.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Pivot.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Order.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	NormalizeNestedDataSet.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Minus.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Matrix.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	MailTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	KeyValueTransformator.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	KeyValueNormTransformator.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Join.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Intersect.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	FilterDataSet.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	Filter.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	FileMerge.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	FileManagerTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	ExtractDimension.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	EvalTransformator.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	CmdTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	AddDimension.executeBeforeEtlTask(EtlConfig config, Task action, Scenario scenario)
TaskResult	XslTransormTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Validator.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Union.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Transpose.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	SqlTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	SplitDataSet.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	ScriptTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	RemoveDuplicates.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	RegexpTransformator.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Populate.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Pivot.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Order.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	NormalizeNestedDataSet.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Minus.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Matrix.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	MailTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	KeyValueTransformator.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	KeyValueNormTransformator.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Join.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Intersect.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	FilterDataSet.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	Filter.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	FileMerge.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	FileManagerTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	ExtractDimension.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	EvalTransformator.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	CopyIntoDestinationTableTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	CmdTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	AddDimension.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	XslTransormTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Validator.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Union.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Transpose.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	SqlTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	SplitDataSet.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	ScriptTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	RemoveDuplicates.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	RegexpTransformator.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Populate.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Pivot.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Order.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	NormalizeNestedDataSet.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario parentScenario)
TaskResult	Minus.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Matrix.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	MailTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	KeyValueTransformator.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	KeyValueNormTransformator.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Join.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Intersect.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	FilterDataSet.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	Filter.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	FileMerge.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	FileManagerTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	ExtractDimension.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	EvalTransformator.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	CopyIntoDestinationTableTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	CmdTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	AddDimension.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	XslTransormTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Validator.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Union.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Transpose.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	SqlTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	SplitDataSet.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	ScriptTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	RemoveDuplicates.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	RegexpTransformator.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Populate.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Pivot.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Order.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	NormalizeNestedDataSet.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Minus.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Matrix.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	MailTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	KeyValueTransformator.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	KeyValueNormTransformator.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Join.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Intersect.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	FilterDataSet.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	Filter.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	FileMerge.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	FileManagerTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	ExtractDimension.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	EvalTransformator.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	CmdTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	AddDimension.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	ScriptTask.executeTask(EtlConfig config, Task task, long index, Scenario scenario, boolean inline) Execute task.
static boolean	FileManagerTask.filesExist(EtlConfig config, String connectionName, String wildcard) Check if files exist using given alias and wildcard file name.
static Alias	FileManagerTask.getAlias(EtlConfig config, String connectionName) Gets the alias by connection name.
static String	FileManagerTask.getFileName(EtlConfig config, String connectionName, String fileName, boolean createFolder) Get the fully qualified file name from the given connection and base file name.
void	XslTransormTask.init(EtlConfig config, Task task)
void	Validator.init(EtlConfig config, Task task)
void	Union.init(EtlConfig config, Task task)
void	Transpose.init(EtlConfig config, Task task)
void	SqlTask.init(EtlConfig config, Task task)
void	SplitDataSet.init(EtlConfig config, Task task)
void	ScriptTask.init(EtlConfig config, Task task)
void	RemoveDuplicates.init(EtlConfig config, Task task)
void	RegexpTransformator.init(EtlConfig config, Task task)
void	Populate.init(EtlConfig config, Task task)
void	Pivot.init(EtlConfig config, Task task)
void	Order.init(EtlConfig config, Task task)
void	NormalizeNestedDataSet.init(EtlConfig config, Task task)
void	Minus.init(EtlConfig config, Task task)
void	Matrix.init(EtlConfig config, Task task)
void	MailTask.init(EtlConfig config, Task task)
void	KeyValueTransformator.init(EtlConfig config, Task task)
void	KeyValueNormTransformator.init(EtlConfig config, Task task)
void	Join.init(EtlConfig config, Task task)
void	Intersect.init(EtlConfig config, Task task)
void	FilterDataSet.init(EtlConfig config, Task task)
void	Filter.init(EtlConfig config, Task task)
void	FileMerge.init(EtlConfig config, Task task)
void	FileManagerTask.init(EtlConfig config, Task task)
void	ExtractDimension.init(EtlConfig config, Task task)
void	EvalTransformator.init(EtlConfig config, Task task)
void	CopyIntoDestinationTableTask.init(EtlConfig config, Task task)
void	CmdTask.init(EtlConfig config, Task task)
void	AddDimension.init(EtlConfig config, Task task)
static List<FileResource>	FileManagerTask.list(EtlConfig config, String connectionName, String wildcard) Get the list of files for the connection and wildcard.
static List<FileResource>	FileManagerTask.list(EtlConfig config, String connectionName, String wildcard, Set<String> excludedObjects, Set<String> includedObjects) Get the list of files for the connection and wildcard.
static Object	FileManagerTask.read(EtlConfig config, String connectionName, String fileName) Read data from the given source.
static InputStream	FileManagerTask.readAsStream(EtlConfig config, String connectionName, String fileName) Read data from the given source.
static boolean	FileManagerTask.saveTemplate(EtlConfig config, String connectionName, String fileName, Object payload, boolean createFolder) Send the template to the given destination.
static Alias	FileManagerTask.updateAlias(EtlConfig config, String connectionName, String fileName) Update alias url using given file name.
static boolean	FileManagerTask.write(EtlConfig config, String connectionName, String fileName, Object payload) Send payload to the given destination.
static boolean	FileManagerTask.write(EtlConfig config, String connectionName, String fileName, Object payload, boolean createFolder) Send payload to the given destination.

Uses of EtlConfig in com.toolsverse.etl.core.task.informix

Methods in com.toolsverse.etl.core.task.informix with parameters of type EtlConfig

Modifier and Type	Method and Description
TaskResult	InformixDbAccessTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
void	InformixLoadTask.init(EtlConfig config, Task task)
void	InformixExtractTask.init(EtlConfig config, Task task)

Uses of EtlConfig in com.toolsverse.etl.core.task.oracle

Methods in com.toolsverse.etl.core.task.oracle with parameters of type EtlConfig

Modifier and Type	Method and Description
TaskResult	OracleLoadTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	OracleExtractTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	OracleCopyTask.executeBeforeEtlTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	OracleLoadTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	OracleExtractTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	OracleCopyTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	OracleLoadTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	OracleExtractTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	OracleCopyTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
TaskResult	OracleLoadTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	OracleExtractTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
TaskResult	OracleCopyTask.executePreTask(EtlConfig config, Task task, Scenario scenario)
void	OracleLoadTask.init(EtlConfig config, Task task)
void	OracleExtractTask.init(EtlConfig config, Task task)
void	OracleCopyTask.init(EtlConfig config, Task task)

Uses of EtlConfig in com.toolsverse.etl.core.task.redshift

Methods in com.toolsverse.etl.core.task.redshift with parameters of type EtlConfig

Modifier and Type	Method and Description
TaskResult	CopyIntoRedshiftTableTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	CopyIntoRedshiftTableTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
void	CopyIntoRedshiftTableTask.init(EtlConfig config, Task task)

Uses of EtlConfig in com.toolsverse.etl.core.task.snowflake

Methods in com.toolsverse.etl.core.task.snowflake with parameters of type EtlConfig

Modifier and Type	Method and Description
TaskResult	CopyIntoTableTask.executeInlineTask(EtlConfig config, Task task, long index, Scenario scenario)
TaskResult	CopyIntoTableTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
void	CopyIntoTableTask.init(EtlConfig config, Task task)

Uses of EtlConfig in com.toolsverse.etl.core.task.sqlserver

Methods in com.toolsverse.etl.core.task.sqlserver with parameters of type EtlConfig

Modifier and Type	Method and Description
TaskResult	BcpTask.executePostTask(EtlConfig config, Task task, DataSet dataSet, Scenario scenario)
String	SybaseBcpTask.getServer(EtlConfig config, Task task)
String	MsSqlBcpTask.getServer(EtlConfig config, Task task)
abstract String	BcpTask.getServer(EtlConfig config, Task task) Gets the server name.
String	SybaseLoadTask.getSql(EtlConfig config, Task task, String datFileName, String params)
String	SybaseExtractTask.getSql(EtlConfig config, Task task, String datFileName, String params)
String	MsSqlLoadTask.getSql(EtlConfig config, Task task, String datFileName, String params)
String	MsSqlExtractTask.getSql(EtlConfig config, Task task, String datFileName, String params)
abstract String	BcpTask.getSql(EtlConfig config, Task task, String datFileName, String params) Gets the sql to execute.

Uses of EtlConfig in com.toolsverse.etl.core.util

Methods in com.toolsverse.etl.core.util with parameters of type EtlConfig

Modifier and Type	Method and Description
static boolean	EtlUtils.checkCondition(EtlConfig config, String name, Scenario scenario, ConditionalExecution conditionalExecution) Checks condition.
static boolean	EtlUtils.checkCondition(EtlConfig config, String name, Scenario scenario, ConditionalExecution conditionalExecution, DataSet dataSet) Checks condition.