|
tCollector
|
Feeds the parallel execution processes with the threads generated by tPartitioner. |
|
tDepartitioner
|
Assembles the outputs of the parallel execution processes so that tRecollector can capture those outputs. |
|
tFlowToIterate
|
Reads data line by line from the input flow and stores the data entries in iterative
global variables. |
|
tForeach
|
Creates a loop on a list for an iterate link. |
|
tInfiniteLoop
|
Executes a task or a Job automatically, based on a loop. |
|
tIterateToFlow
|
Transforms non processable data into a processable flow.
|
|
tLoop
|
Executes a task or a Job automatically, based on a loop |
|
tParallelize
|
Manages complex Job systems. It executes several subJobs simultaneously and
synchronizes the execution of a subJob with other subJobs within the main Job. |
|
tPartitioner
|
Partitions the input data before tCollector
can transfer them to the parallel execution processes. |
|
tPostjob
|
Triggers a task required after the execution of a Job |
|
tPrejob
|
Triggers a task required for the execution of a Job |
|
tRecollector
|
Outputs of the parallel execution results, depending on tDepartitioner. |
|
tReplicate
|
Duplicates the incoming schema into two identical output flows. |
|
tRunJob
|
Manages complex Job systems which need to execute one Job after
another. |
|
tSleep
|
Identifies possible bottlenecks using a time break in the Job for testing or
tracking purpose. |
|
tUnite
|
Centralizes data from various and heterogeneous sources. |
|
tWaitForFile
|
Iterates on a directory and triggers the next component when the defined condition
is met. |
|
tWaitForSocket
|
Triggers a Job based on a defined condition. |
|
tWaitForSqlData
|
Iterates on a given connection for insertion or deletion of rows and triggers a
subJob when a condition linked to SQL data presence is met. |
