Modifier and Type | Class and Description |
---|---|
class |
DataSetFields
The
DataSet fields. |
Modifier and Type | Method and Description |
---|---|
TypedKeyValue<List<String>,List<String>> |
DataSet.updateFromMetadata(LinkedHashMap<String,FieldDef> metadata,
boolean source,
boolean dest,
boolean create,
boolean alter,
boolean orderAndType,
boolean typeOnly,
ListHashMap<String,Variable> variables)
Update fields from metadata.
|
Modifier and Type | Method and Description |
---|---|
ListHashMap<String,String> |
SqlConnectorParams.getFieldsMapping()
Gets the fields mapping.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlConnectorParams.setFieldsMapping(ListHashMap<String,String> value)
Sets the fields mapping.
|
Modifier and Type | Method and Description |
---|---|
ListHashMap<String,Task> |
Source.getBeforeEtlTasks() |
ListHashMap<String,Task> |
Destination.getBeforeEtlTasks() |
ListHashMap<String,Task> |
Block.getBeforeEtlTasks()
Gets the tasks which are executed before etl framework starts processing
the
DataSet object associated with the particular scenario
block but after initializing is done. |
ListHashMap<String,Destination> |
Scenario.getDestinations()
Gets the destinations.
|
ListHashMap<String,Task> |
Source.getInlineTasks() |
ListHashMap<String,Task> |
Destination.getInlineTasks() |
ListHashMap<String,Task> |
Block.getInlineTasks()
Gets the tasks which are executed for each row of the
DataSet object associated with the scenario block. |
ListHashMap<String,Source> |
Scenario.getMandatorySources()
Gets the list of mandatory sources.
|
ListHashMap<String,Task> |
Source.getOnExceptionTasks() |
ListHashMap<String,Task> |
Destination.getOnExceptionTasks() |
ListHashMap<String,Task> |
Block.getOnExceptionTasks()
Gets the tasks which are executed when there is an exception during processing of the etl block.
|
ListHashMap<String,Task> |
Source.getPostTasks() |
ListHashMap<String,Task> |
Destination.getPostTasks() |
ListHashMap<String,Task> |
Block.getPostTasks()
Gets the tasks which are executed after etl framework finished with the
processing of the particular scenario block.
|
ListHashMap<String,Variable> |
Destination.getScenarioVariables()
Gets the variables linked to the scenario.
|
ListHashMap<String,Source> |
Scenario.getSources()
Gets the sources.
|
ListHashMap<String,Task> |
Source.getTasks() |
ListHashMap<String,Task> |
Destination.getTasks() |
ListHashMap<String,Task> |
Block.getTasks()
Gets the tasks which are executed before etl framework starts processing
of the particular scenario block.
|
ListHashMap<String,Variable> |
Task.getVariables()
Gets the variables.
|
ListHashMap<String,Variable> |
Source.getVariables() |
ListHashMap<String,Variable> |
Scenario.getVariables()
Gets the variables.
|
ListHashMap<String,Variable> |
Destination.getVariables() |
ListHashMap<String,Variable> |
Block.getVariables()
Gets the variables.
|
Modifier and Type | Method and Description |
---|---|
void |
Task.addVariables(ListHashMap<String,Variable> value)
Adds the variables.
|
void |
Scenario.setAfterTasks(ListHashMap<String,Task> tasks)
Sets the tasks executed after ETL.
|
void |
Source.setBeforeEtlTasks(ListHashMap<String,Task> value) |
void |
Destination.setBeforeEtlTasks(ListHashMap<String,Task> value) |
void |
Block.setBeforeEtlTasks(ListHashMap<String,Task> value)
Sets the tasks which are executed before etl framework starts processing
the
DataSet object associated with the particular scenario
block but after initializing is done. |
void |
Scenario.setBeforeTasks(ListHashMap<String,Task> tasks)
Set the tasks executed before ETL.
|
void |
Scenario.setDestinations(ListHashMap<String,Destination> value)
Sets the destinations.
|
void |
Source.setInlineTasks(ListHashMap<String,Task> value) |
void |
Destination.setInlineTasks(ListHashMap<String,Task> value) |
void |
Block.setInlineTasks(ListHashMap<String,Task> value)
Sets the tasks which are executed for each row of the
DataSet object associated with the scenario block. |
void |
Scenario.setMandatorySources(ListHashMap<String,Source> value)
Sets the mandatory sources.
|
void |
Source.setOnExceptionTasks(ListHashMap<String,Task> value) |
void |
Destination.setOnExceptionTasks(ListHashMap<String,Task> value) |
void |
Block.setOnExceptionTasks(ListHashMap<String,Task> value)
Sets the tasks which are executed when there is an exception during processing of the etl block.
|
void |
Source.setPostTasks(ListHashMap<String,Task> value) |
void |
Destination.setPostTasks(ListHashMap<String,Task> value) |
void |
Block.setPostTasks(ListHashMap<String,Task> value)
Sets the tasks which are executed after etl framework finished with the
processing of the particular scenario block.
|
void |
Destination.setScenarioVariables(ListHashMap<String,Variable> value)
Sets the variables which belongs to the scenario.
|
void |
Scenario.setSources(ListHashMap<String,Source> value)
Sets the sources.
|
void |
Source.setTasks(ListHashMap<String,Task> value) |
void |
Destination.setTasks(ListHashMap<String,Task> value) |
void |
Block.setTasks(ListHashMap<String,Task> value)
Sets the tasks which are executed before etl framework starts processing
of the particular scenario block.
|
void |
Task.setVariables(ListHashMap<String,Variable> value)
Sets the variables.
|
void |
Source.setVariables(ListHashMap<String,Variable> value) |
void |
Scenario.setVariables(ListHashMap<String,Variable> value)
Sets the variables.
|
void |
Destination.setVariables(ListHashMap<String,Variable> value) |
void |
Block.setVariables(ListHashMap<String,Variable> value)
Sets the variables for the block.
|
Modifier and Type | Method and Description |
---|---|
protected String |
DefFunctions.getVarSql(ListHashMap<String,Variable> variables,
Variable var,
Driver driver,
Map<String,Variable> candidates)
Gets the sql associated with the variable.
|
Modifier and Type | Method and Description |
---|---|
static Variable |
EtlUtils.addVar(ListHashMap<String,Variable> vars,
String name,
String defValue,
boolean replace)
Creates a new variable and adds it to the given map.
|
static String |
EtlUtils.getVarValue(ListHashMap<String,Variable> vars,
String name,
String defValue)
Gets the variable value.
|
static String |
EtlUtils.mergeSqlWithVars(CacheProvider<String,Object> cacheProvider,
String sql,
String using,
ListHashMap<String,Variable> variables,
Map<String,Object> bindVars)
Merges sql with variables.
|
static String |
EtlUtils.mergeSqlWithVars(String sql,
ListHashMap<String,Variable> vars,
Driver driver)
Merges sql with variables.
|
static void |
EtlUtils.substituteVars(ListHashMap<String,Variable> variables)
Substitute variable values in {} brackets.
|
Modifier and Type | Method and Description |
---|---|
static void |
SqlUtils.populateDataSet(DataSet dataSet,
Driver driver,
ResultSet rs,
ListHashMap<String,String> fieldsMapping,
boolean unique,
boolean checkKeyField)
Populates data set from the result set.
|
static void |
SqlUtils.populateDataSet(DataSet dataSet,
Driver driver,
ResultSet rs,
ListHashMap<String,String> fieldsMapping,
boolean unique,
boolean checkKeyField,
String filterByField,
String filterByFieldValue)
Populates data set from the result set.
|
static void |
SqlUtils.populateDataSet(DataSet dataSet,
Driver driver,
ResultSet rs,
ListHashMap<String,String> fieldsMapping,
boolean unique,
boolean checkKeyField,
String filterByField,
String filterByFieldValue,
int maxRows,
boolean ignoreGetObjectErrors)
Populates data set from the result set.
|
Modifier and Type | Method and Description |
---|---|
void |
ListHashMap.copyAll(ListHashMap<K,V> source)
Copy all elements from the source map.
|
Copyright © 2010-2020 Toolsverse. All Rights Reserved.