public class Scenario extends ConditionalExecution implements Serializable, LocationProvider
EtlProcess
. Generally speaking etl scenario is a program
in the domain specific language. It can include code in other languages as
well, for example SQL and JavaScript.Modifier and Type | Field and Description |
---|---|
static String |
ACTION_ATTR
The Constant ACTION_ATTR.
|
static String |
ALLOW_ATTR
The Constant ALLOW_ATTR.
|
static String |
COND_ATTR
The Constant COND_ATTR.
|
static String |
COND_CONNECTION_ATTR
The Constant COND_CONNECTION_ATTR.
|
static String |
COND_LANG_ATTR
The Constant COND_LANG_ATTR.
|
static String |
CONNECTION_ATTR
The Constant CONNECTION_ATTR.
|
static String |
COUNT_ATTR
The COUNT_ATTR.
|
static String |
DEFAULT_CODEGEN_CLASS
The DEFAULT_CODEGEN_CLASS.
|
static String |
DESCRIPTION_ATTR
The Constant DESCRIPTION_ATTR.
|
static String |
ETL_DRIVER_ATTR
The Constant ETL_DRIVER_ATTR.
|
static String |
FIELD_ATTR
The Constant FIELD_ATTR.
|
static String |
FUNCTION_ATTR
The Constant FUNCTION_ATTR.
|
static String |
INNER_PARALLEL_ATTR
The Constant INNER_PARALLEL_ATTR.
|
static String |
INNER_SCENARIO_ATTR
The Constant INNER_SCENARIO_ATTR.
|
static String |
INNER_SCENARIO_ON_EXCEPTION_ATTR
The Constant INNER_SCENARIO_ON_EXCEPTION_ATTR.
|
static String |
LOOP_ATTR
The Constant LOOP_ATTR.
|
static String |
LOOP_CONNECTION_ATTR
The Constant LOOP_CONNECTION_ATTR.
|
static String |
LOOP_LANG_ATTR
The Constant LOOP_LANG_ATTR.
|
static String |
LOOP_THREADS_ATTR
The LOOP_THREADS_ATTR.
|
static String |
MAXIMUM_ATTR
The MAXIMUM_ATTR.
|
static String |
MERGE_METRICS_ATTR
The Constant MERGE_METRICS_ATTR.
|
static String |
METADATA_ATTR
The Constant METADATA_ATTR.
|
static String |
METADATA_INDEXES_ATTR
The Constant METADATA_INDEXES_ATTR.
|
static String |
METADATA_SUFFIX_ATTR
The Constant METADATA_SUFFIX_ATTR.
|
static String |
METADATA_TYPES_ATTR
The Constant METADATA_TYPES_ATTR.
|
static String |
METRICS_ATTR
The Constant METRICS_ATTR.
|
static String |
METRICS_FOLDER_ATTR
The METRICS_FOLDER_ATTR.
|
static String |
NAME_ATTR
The Constant NAME_ATTR.
|
static String |
NO_TEMP_TABLES_ATTR
The NO_TEMP_TABLES_ATTR.
|
static Map<String,Integer> |
ON_ACTION
The ON_ACTION mapping.
|
static int |
ON_ACTION_PARENT
The ON_ACTION_PARENT - same behavior as parent scenario.
|
static int |
ON_ACTION_SAVE
The ON_ACTION_SAVE - save file when event occurs.
|
static String |
ON_ACTION_SAVE_STR
The ON_ACTION_SAVE_STR - the ON_ACTION_SAVE code.
|
static int |
ON_ACTION_SKIP
The ON_ACTION_SKIP - do not save file when event occurs.
|
static String |
ON_ACTION_SKIP_STR
The ON_ACTION_SKIP_STR - the ON_ACTION_SKIP code.
|
static String |
ON_EXECUTE_ATTR
The Constant ON_EXECUTE_ATTR.
|
static String |
ON_PERSIST_ATTR
The Constant ON_PERSIST_ATTR.
|
static String |
ON_POPULATE_ATTR
The Constant ON_POPULATE_ATTR.
|
static String |
ON_SAVE_ATTR
The Constant ON_SAVE_ATTR.
|
static String |
ON_TEMP_ATTR
The Constant ON_TEMP_ATTR.
|
static String |
PARALLEL_ATTR
The Constant PARALLEL_ATTR.
|
static String |
PARENT_ETL_DRIVER_ATTR
The Constant PARENT_ETL_DRIVER_ATTR.
|
static String |
PATTERN_ATTR
The Constant PATTERN_ATTR.
|
static String |
REQUIRE_DEST_ATTR
The REQUIRE_DEST_ATTR.
|
static String |
REQUIRE_SOURCE_ATTR
The REQUIRE_SOURCE_ATTR.
|
static String |
SC_REQUIRE_DEST_ATTR
The Constant SC_REQUIRE_DEST_ATTR.
|
static String |
SC_REQUIRE_SOURCE_ATTR
The Constant SC_REQUIRE_SOURCE_ATTR.
|
static String |
SCENARIO_ATTR
The Constant SCENARIO_ATTR.
|
static String |
SCRIPT_ATTR
The Constant SCRIPT_ATTR.
|
static String |
SOURCE_ETL_DRIVER_ATTR
The Constant SOURCE_ETL_DRIVER_ATTR.
|
static String |
SOURCE_PARENT_ETL_DRIVER_ATTR
The Constant SOURCE_PARENT_ETL_DRIVER_ATTR.
|
static String |
VARIABLE_ATTR
The Constant VARIABLE_ATTR.
|
static String |
WRITE_METRICS_ATTR
The Constant WRITE_METRICS_ATTR.
|
Constructor and Description |
---|
Scenario()
Instantiates a new etl scenario.
|
Modifier and Type | Method and Description |
---|---|
void |
addDestination(Destination destination)
Adds the destination.
|
void |
addParallelInnerScenario()
Adds the parallel inner scenario.
|
void |
addSource(Source source)
Adds the source.
|
void |
addVariable(Variable var)
Adds the variable.
|
void |
assignVars(Scenario toScenario)
Assign variables from this scenario to the
toScenario . |
void |
clearAttr(String name)
Removes attribute.
|
void |
clearInnerScenarios()
Clear inner scenarios.
|
int |
getAction()
Gets the action.
|
String |
getAllowedActions()
Gets the allowed actions.
|
Map<String,String> |
getAttrs()
Gets the attributes.
|
String |
getAttrValue(String name)
Gets the attribute value by name.
|
String |
getCodeGenClass()
Gets the code generator class name.
|
String |
getDefaultConnectionName()
Gets the default connection name.
|
String |
getDefaultFunctionClass()
Gets the default function class name.
|
Map<String,Object> |
getDefaultValues()
Gets the default values for the model used to edit scenario.
|
String |
getDescription()
Gets the description.
|
String |
getDestConnectionName()
Gets the default destination connection name.
|
Destination |
getDestinationBySource(Source source)
Gets the destination by source.
|
ListHashMap<String,Destination> |
getDestinations()
Gets the destinations.
|
String |
getDriverClassName()
Gets the default destination driver class name.
|
Point |
getEndLocation()
Gets the end location.
|
EtlMetricsTracker |
getEtlMetricsTracker()
Gets the etl metrics tracker.
|
Exception |
getException()
Gets the exception.
|
List<Scenario> |
getExecute()
Gets the list of inner scenarios.
|
int |
getExecutedBlocks()
Gets the number of executed blocks (tasks, scenarios, sources and
destinations).
|
String |
getId()
Gets the unique id.
|
String |
getIdForException()
Gets the id for exception.
|
Map<String,Object> |
getInnerDefaultValues()
Gets the default values for the model used to edit inner scenario.
|
TypedKeyValue<Point,Point> |
getLocation(String key)
Gets the location of the collection artifact such as sources,
destinations, variables, etc.
|
Map<String,TypedKeyValue<Point,Point>> |
getLocations()
The the locations of the collection artifacts such as sources,
destinations, etc.
|
String |
getLoopCode()
Gets the loop code.
|
String |
getLoopConnectionName()
Gets the loop connection name.
|
String |
getLoopCount()
Gets the loop count.
|
String |
getLoopField()
Gets the loop field.
|
String |
getLoopLang()
Gets the loop language.
|
int |
getLoopThreads()
Gets the loop threads.
|
String |
getLoopVarName()
Gets the loop variable name.
|
String |
getLoopVarPattern()
Gets the loop variable pattern.
|
ListHashMap<String,Source> |
getMandatorySources()
Gets the list of mandatory sources.
|
int |
getMaxLoopIterations()
Gets the maximum number of loop iterations.
|
String |
getMetadataExtractorClass()
Gets the metadata extractor class name.
|
String |
getMetricsFolder()
Gets the metrics folder.
|
String |
getMetricsToWriteFileName()
Gets the name of the file to write metrics to.
|
String |
getName()
Gets the name.
|
String |
getOnException()
Gets the on exception action.
|
int |
getOnPersistDataSet()
Gets the action for "on persist data set" event.
|
int |
getOnPersistDataSet(String action)
Gets the action for "on persist data set" event from the string.
|
int |
getOnPopulateDataSet()
Gets the action for "on populate data set" event.
|
int |
getOnPopulateDataSet(String action)
Gets the action for "on populate data set" event from the string.
|
int |
getOnSave()
Gets the action for "on save" event.
|
int |
getOnSave(String action)
Gets the action for "on save" event.
|
int |
getParallelDests()
Gets the count of the destinations which loaded in parallel threads.
|
int |
getParallelInnerScenarious()
Gets the count inner scenarios which executed in parallel threads.
|
int |
getParallelSources()
Gets the count of the sources which extracted in parallel threads.
|
String |
getScriptName()
Gets the script name.
|
String |
getSourceDriverClassName()
Gets the default source driver class name.
|
ListHashMap<String,Source> |
getSources()
Gets the sources.
|
Point |
getStartLocation()
Gets the start location.
|
boolean |
getUseMetadataDataTypes()
Gets the global "use metadata data types" flag.
|
String |
getUuid()
Gets the uuid.
|
Variable |
getVariable(String name)
Gets the variable by name.
|
ListHashMap<String,Variable> |
getVariables()
Gets the variables.
|
String |
getVariableValue(String name)
Gets the variable value.
|
String |
getWriteMetrics()
Gets the format to write metrics to.
|
boolean |
hasDestinationsWithNewConnection()
Checks if scenario has destinations with new connection flag enabled.
|
int |
incExecutedBlocks()
Increment number of executed blocks (tasks, scenarios, sources and
destinations).
|
boolean |
isAttrSet(String name)
Checks if attribute is set and equals to true.
|
boolean |
isCommitEachBlock()
Checks if engine should commit each block.
|
boolean |
isCreatedToHandleFileLoop()
Checks if this scenario is created to handle file loop.
|
boolean |
isEnabled()
Checks if scenario enabled.
|
boolean |
isInner()
Checks if this scenario is inner.
|
boolean |
isMergeMetrics()
Checks if is merge metrics.
|
boolean |
isParallelConnections()
Checks if scenario requires parallel connections.
|
boolean |
isParallelInnerScenario()
Checks if this is a parallel inner scenario.
|
boolean |
isParallelScenario()
Checks if this is a parallel scenario.
|
boolean |
isReady()
Checks if scenario is fully loaded and ready to be executed.
|
boolean |
isTrackMetrics()
Checks if is track metrics.
|
void |
setAction(int value)
Sets the action.
|
void |
setAfterTasks(ListHashMap<String,Task> tasks)
Sets the tasks executed after ETL.
|
void |
setAllowedActions(String value)
Sets the allowed actions.
|
void |
setAttrs(Map<String,String> value)
Sets the attributes.
|
void |
setAttrValue(String name,
String value)
Sets the attribute value.
|
void |
setBeforeTasks(ListHashMap<String,Task> tasks)
Set the tasks executed before ETL.
|
void |
setCodeGenClass(String value)
Sets the code generator class name.
|
void |
setCommitEachBlock(boolean value)
Sets the "commit each block" flag.
|
void |
setCreatedToHandleFileLoop(boolean createdToHandleFileLoop)
Sets the value for the flag "created to handle file loop".
|
void |
setDefaultFunctionClass(String value)
Sets the default function class name.
|
void |
setDescription(String value)
Sets the description.
|
void |
setDestConnectionName(String value)
Sets the destination connection name.
|
void |
setDestinations(ListHashMap<String,Destination> value)
Sets the destinations.
|
void |
setDriver(String value)
Sets the default destination driver class name.
|
void |
setEnabled(boolean enabled)
Sets the enabled flag for the scenario.
|
void |
setEtlMetricsTracker(EtlMetricsTracker etlMetricsTracker)
Sets the etl metrics tracker.
|
void |
setException(Exception ex)
Sets the exception.
|
void |
setExecute(List<Scenario> value)
Sets the list of inner scenarios.
|
void |
setHasDestinationsWithNewConnection(boolean hasDestinationsWithNewConnection)
Sets the value of the flag hasDestinationsWithNewConnection.
|
void |
setId(String value)
Sets the unique id.
|
protected void |
setIsInner(boolean value)
Sets "is inner" flag.
|
void |
setLocation(boolean doSet,
String key,
org.w3c.dom.Node treesNode)
Set the location for the artifacts such as sources, destinations, etc.
|
void |
setLocation(boolean doSet,
String key,
TypedKeyValue<Point,Point> location)
Set the location for the artifacts such as sources, destinations, etc.
|
void |
setLoopCode(String value)
Sets the loop code.
|
void |
setLoopConnectionName(String value)
Sets the loop connection name.
|
void |
setLoopCount(String value)
Sets the loop count.
|
void |
setLoopField(String value)
Sets the loop field.
|
void |
setLoopLang(String value)
Sets the loop language.
|
void |
setLoopThreads(int loopThreads)
Sets the loop threads.
|
void |
setLoopVarName(String value)
Sets the loop variable name.
|
void |
setLoopVarPattern(String value)
Sets the loop variable pattern.
|
void |
setMandatorySources(ListHashMap<String,Source> value)
Sets the mandatory sources.
|
void |
setMaxLoopIterations(int maxLoopIterations)
Sets the maximum number of loop iterations.
|
void |
setMergeMetrics(boolean mergeMetrics)
Sets the merge metrics.
|
void |
setMetadataExtractorClass(String value)
Sets the metadata extractor class name.
|
void |
setMetricsFolder(String metricsFolder)
Sets the metrics folder.
|
void |
setName(String value)
Sets the name.
|
void |
setOnException(String onException)
Sets the on exception action.
|
void |
setOnPersistDataSet(int value)
Sets the action for "on persist data set" event.
|
void |
setOnPersistDataSet(String action)
Sets the action for "on persist data set" event from the string.
|
void |
setOnPopulateDataSet(int value)
Sets the action for "on populate data set" event.
|
void |
setOnPopulateDataSet(String action)
Sets the action for "on populate data set" event from the string.
|
void |
setOnSave(int value)
Sets the action for "on save" event.
|
void |
setOnSave(String action)
Sets the action for "on save" event from the string.
|
void |
setParallelConnections(boolean value)
Sets "has parallel connections" flag.
|
void |
setParallelDests(int value)
Sets the count of parallel destinations.
|
void |
setParallelInnerScenario(boolean value)
Sets the "is parallel inner scenario" flag.
|
void |
setParallelScenario(boolean value)
Sets the "is parallel scenario" flag.
|
void |
setParallelSources(int value)
Sets the count of parallel sources.
|
void |
setReady(boolean value)
Sets ready status for the scenario.
|
void |
setScriptName(String value)
Sets the script name.
|
void |
setSourceDriver(String value)
Sets the default source driver class name.
|
void |
setSources(ListHashMap<String,Source> value)
Sets the sources.
|
void |
setTrackMetrics(boolean trackMetrics)
Sets the track metrics.
|
void |
setUseMetadataDataTypes(boolean value)
Sets the "use metadata data types" flag.
|
void |
setUuid(String uuid)
Sets the uuid.
|
void |
setVariables(ListHashMap<String,Variable> value)
Sets the variables.
|
void |
setWriteMetrics(String writeMetrics)
Sets the format to write metrics to.
|
void |
updateConsolidatedMetrics(List<Map<String,EtlMetrics>> metrics,
Map<String,FileMetrics> fileMetrics)
Update consolidated metrics.
|
getConditionCode, getConditionConnectionName, getConditionLang, setConditionCode, setConditionConnectionName, setConditionLang
public static final String DEFAULT_CODEGEN_CLASS
public static final String SCENARIO_ATTR
public static final String INNER_SCENARIO_ATTR
public static final String NAME_ATTR
public static final String ACTION_ATTR
public static final String INNER_PARALLEL_ATTR
public static final String INNER_SCENARIO_ON_EXCEPTION_ATTR
public static final String SCRIPT_ATTR
public static final String DESCRIPTION_ATTR
public static final String PARALLEL_ATTR
public static final String METRICS_ATTR
public static final String WRITE_METRICS_ATTR
public static final String MERGE_METRICS_ATTR
public static final String METRICS_FOLDER_ATTR
public static final String ALLOW_ATTR
public static final String ON_EXECUTE_ATTR
public static final String SC_REQUIRE_SOURCE_ATTR
public static final String SC_REQUIRE_DEST_ATTR
public static final String ON_TEMP_ATTR
public static final String ETL_DRIVER_ATTR
public static final String PARENT_ETL_DRIVER_ATTR
public static final String SOURCE_ETL_DRIVER_ATTR
public static final String SOURCE_PARENT_ETL_DRIVER_ATTR
public static final String ON_PERSIST_ATTR
public static final String ON_POPULATE_ATTR
public static final String ON_SAVE_ATTR
public static final String CONNECTION_ATTR
public static final String METADATA_ATTR
public static final String METADATA_TYPES_ATTR
public static final String METADATA_INDEXES_ATTR
public static final String METADATA_SUFFIX_ATTR
public static final String FUNCTION_ATTR
public static final String COND_LANG_ATTR
public static final String COND_ATTR
public static final String COND_CONNECTION_ATTR
public static final String LOOP_LANG_ATTR
public static final String LOOP_ATTR
public static final String VARIABLE_ATTR
public static final String PATTERN_ATTR
public static final String FIELD_ATTR
public static final String LOOP_CONNECTION_ATTR
public static final String COUNT_ATTR
public static final String MAXIMUM_ATTR
public static final String LOOP_THREADS_ATTR
public static final int ON_ACTION_PARENT
public static final int ON_ACTION_SAVE
public static final int ON_ACTION_SKIP
public static final String ON_ACTION_SAVE_STR
public static final String ON_ACTION_SKIP_STR
public static final Map<String,Integer> ON_ACTION
public static final String REQUIRE_SOURCE_ATTR
public static final String REQUIRE_DEST_ATTR
public static final String NO_TEMP_TABLES_ATTR
public void addDestination(Destination destination)
destination
- the destination to addpublic void addParallelInnerScenario()
public void clearInnerScenarios()
public void addSource(Source source)
source
- the source to addpublic void addVariable(Variable var)
var
- the variablepublic void assignVars(Scenario toScenario)
toScenario
.toScenario
- the scenario to assign variables from thispublic void clearAttr(String name)
name
- the namepublic int getAction()
public String getAllowedActions()
public Map<String,String> getAttrs()
public String getAttrValue(String name)
name
- the attribute name.public String getCodeGenClass()
public String getDefaultConnectionName()
ConditionalExecution
getDefaultConnectionName
in class ConditionalExecution
public String getDefaultFunctionClass()
public Map<String,Object> getDefaultValues()
public String getDescription()
public String getDestConnectionName()
public Destination getDestinationBySource(Source source)
source
- the sourcepublic ListHashMap<String,Destination> getDestinations()
public String getDriverClassName()
public Point getEndLocation()
LocationProvider
getEndLocation
in interface LocationProvider
public EtlMetricsTracker getEtlMetricsTracker()
public Exception getException()
public List<Scenario> getExecute()
public int getExecutedBlocks()
public String getId()
public Map<String,Object> getInnerDefaultValues()
public TypedKeyValue<Point,Point> getLocation(String key)
key
- the artifact type namepublic Map<String,TypedKeyValue<Point,Point>> getLocations()
public String getLoopCode()
public String getLoopConnectionName()
getLoopCode()
.public String getLoopCount()
public String getLoopField()
public String getLoopLang()
getLoopCode()
. Currently supported languages: SQL,
JavaScript.public String getLoopVarName()
public String getLoopVarPattern()
public ListHashMap<String,Source> getMandatorySources()
public String getMetadataExtractorClass()
public String getMetricsFolder()
public String getMetricsToWriteFileName()
public String getName()
public String getOnException()
public int getOnPersistDataSet()
public int getOnPersistDataSet(String action)
action
- the actionpublic int getOnPopulateDataSet()
public int getOnPopulateDataSet(String action)
action
- the actionpublic int getOnSave()
public int getOnSave(String action)
action
- the actionpublic int getParallelDests()
public int getParallelInnerScenarious()
public int getParallelSources()
public String getScriptName()
public String getSourceDriverClassName()
public ListHashMap<String,Source> getSources()
public Point getStartLocation()
LocationProvider
getStartLocation
in interface LocationProvider
public boolean getUseMetadataDataTypes()
public Variable getVariable(String name)
name
- the namepublic String getVariableValue(String name)
name
- the namepublic ListHashMap<String,Variable> getVariables()
public String getWriteMetrics()
public int incExecutedBlocks()
public boolean isAttrSet(String name)
name
- the namepublic boolean isCommitEachBlock()
public boolean isInner()
public boolean isMergeMetrics()
public boolean isParallelConnections()
public boolean isParallelInnerScenario()
public boolean isParallelScenario()
public boolean isReady()
public boolean isTrackMetrics()
public void setAction(int value)
value
- the new actionpublic void setAfterTasks(ListHashMap<String,Task> tasks)
tasks
- the tasks to set as "post tasks"public void setAllowedActions(String value)
value
- the new allowed actionspublic void setAttrs(Map<String,String> value)
value
- the new attributespublic void setAttrValue(String name, String value)
name
- the namevalue
- the valuepublic void setBeforeTasks(ListHashMap<String,Task> tasks)
tasks
- the tasks to set as "before tasks"public void setCodeGenClass(String value)
value
- the new code generator class namepublic void setCommitEachBlock(boolean value)
value
- the new value for the "commit each block" flagpublic void setDefaultFunctionClass(String value)
value
- the new default function class namepublic void setDescription(String value)
value
- the new descriptionpublic void setDestConnectionName(String value)
value
- the new destination connection namepublic void setDestinations(ListHashMap<String,Destination> value)
value
- the destinationspublic void setDriver(String value)
value
- the new driver class namepublic void setEtlMetricsTracker(EtlMetricsTracker etlMetricsTracker)
etlMetricsTracker
- the etlMetricsTracker to setpublic void setException(Exception ex)
ex
- the new exceptionpublic void setExecute(List<Scenario> value)
value
- the list of inner scenariospublic void setId(String value)
value
- the new unique idprotected void setIsInner(boolean value)
value
- the new "is inner" flagpublic void setLocation(boolean doSet, String key, org.w3c.dom.Node treesNode)
doSet
- if false do not add location info for the artifactkey
- the artifact typetreesNode
- the DOM node which holds location informationpublic void setLocation(boolean doSet, String key, TypedKeyValue<Point,Point> location)
doSet
- if false do not add location info for the artifactkey
- the artifact typelocation
- the locationpublic void setLoopCode(String value)
value
- the new loop codepublic void setLoopConnectionName(String value)
value
- the new loop connection namepublic void setLoopCount(String value)
value
- the new loop countpublic void setLoopField(String value)
value
- the new loop fieldpublic void setLoopLang(String value)
value
- the new loop languagepublic void setLoopVarName(String value)
value
- the new loop variable namepublic void setLoopVarPattern(String value)
value
- the new loop variable patternpublic void setMandatorySources(ListHashMap<String,Source> value)
value
- the mandatory sourcespublic void setMergeMetrics(boolean mergeMetrics)
mergeMetrics
- the mergeMetrics to setpublic void setMetadataExtractorClass(String value)
value
- the new metadata extractor class namepublic void setMetricsFolder(String metricsFolder)
metricsFolder
- the metricsFolder to setpublic void setName(String value)
value
- the new namepublic void setOnException(String onException)
onException
- the onException to setpublic void setOnPersistDataSet(int value)
value
- the action for "on persist data set" eventpublic void setOnPersistDataSet(String action)
action
- the new action for "on persist data set" eventpublic void setOnPopulateDataSet(int value)
value
- the new action for "on populate data set" eventpublic void setOnPopulateDataSet(String action)
action
- the new action for "on populate data set" eventpublic void setOnSave(int value)
value
- the new action for "on save" eventpublic void setOnSave(String action)
action
- the new action for "on save" eventpublic void setParallelConnections(boolean value)
value
- the "has parallel connections" flagpublic void setParallelDests(int value)
value
- the count of parallel destinationspublic void setParallelInnerScenario(boolean value)
value
- the "is parallel inner scenario" flagpublic void setParallelScenario(boolean value)
value
- the "is parallel scenario" flagpublic void setParallelSources(int value)
value
- the count of parallel sources.public void setReady(boolean value)
value
- the ready statuspublic void setScriptName(String value)
value
- the new script namepublic void setSourceDriver(String value)
value
- the new driver class namepublic void setSources(ListHashMap<String,Source> value)
value
- the sourcespublic void setTrackMetrics(boolean trackMetrics)
trackMetrics
- the trackMetrics to setpublic void setUseMetadataDataTypes(boolean value)
value
- the "use metadata data types" flagpublic void setVariables(ListHashMap<String,Variable> value)
value
- the variablespublic void setWriteMetrics(String writeMetrics)
writeMetrics
- the formatpublic int getMaxLoopIterations()
public void setMaxLoopIterations(int maxLoopIterations)
maxLoopIterations
- int. -1 = no limitpublic boolean isCreatedToHandleFileLoop()
public void setCreatedToHandleFileLoop(boolean createdToHandleFileLoop)
createdToHandleFileLoop
- the new value for the flag "created to handle file loop"public int getLoopThreads()
public void setLoopThreads(int loopThreads)
loopThreads
- the new loop threadspublic boolean isEnabled()
public void setEnabled(boolean enabled)
enabled
- the new value of the enabled flagpublic String getIdForException()
ConditionalExecution
getIdForException
in class ConditionalExecution
public void updateConsolidatedMetrics(List<Map<String,EtlMetrics>> metrics, Map<String,FileMetrics> fileMetrics)
metrics
- the metricsfileMetrics
- the file metricspublic String getUuid()
public void setUuid(String uuid)
uuid
- the new uuidpublic boolean hasDestinationsWithNewConnection()
public void setHasDestinationsWithNewConnection(boolean hasDestinationsWithNewConnection)
hasDestinationsWithNewConnection
- booleanCopyright © 2010-2020 Toolsverse. All Rights Reserved.