July 30, 2023

tRowGenerator – Docs for ESB 7.x

tRowGenerator

Creates an input flow in a Job for testing purposes, in particular for boundary
test sets.

tRowGenerator generates as many rows and fields as are required
using random values taken from a list.

Depending on the Talend
product you are using, this component can be used in one, some or all of the following
Job frameworks:

The tRowGenerator Editor opens up on a separate window
made of two parts: a Schema definition panel at the top of the window and a Function
definition and preview panel at the bottom.

tRowGenerator Standard properties

These properties are used to configure tRowGenerator running in
the Standard Job framework.

The Standard
tRowGenerator component belongs to the Misc family.

The component in this framework is available in all Talend
products
.

Basic settings

Schema and Edit
schema

A schema is a row description. It defines the number of fields
(columns) to be processed and passed on to the next component. When you create a Spark
Job, avoid the reserved word line when naming the
fields.

Click Edit
schema
to make changes to the schema. If the current schema is of the Repository type, three options are available:

  • View schema: choose this
    option to view the schema only.

  • Change to built-in property:
    choose this option to change the schema to Built-in for local changes.

  • Update repository connection:
    choose this option to change the schema stored in the repository and decide whether
    to propagate the changes to all the Jobs upon completion. If you just want to
    propagate the changes to the current Job, you can select No upon completion and choose this schema metadata
    again in the Repository Content
    window.

 

Built-In: You create and store the schema locally for this component
only.

 

Repository: You have already created the schema and stored it in the
Repository. You can reuse it in various projects and Job designs.

RowGenerator editor

The editor allows you to define the columns and the nature of
data to be generated. You can use predefined routines or type in the function
to be used to generate the data specified.

Note that in a Storm Job, the value -1
in the Number of rows for RowGenerator
field in the RowGenerator editor means
to generate infinite rows of input data.

Advanced settings

tStatCatcher Statistics

Select this check box to collect log data at the component
level.

Global Variables

Global Variables

NB_LINE: the number of rows processed. This is an After
variable and it returns an integer.

ERROR_MESSAGE: the error message generated by the
component when an error occurs. This is an After variable and it returns a string. This
variable functions only if the Die on error check box is
cleared, if the component has this check box.

A Flow variable functions during the execution of a component while an After variable
functions after the execution of the component.

To fill up a field or expression with a variable, press Ctrl +
Space
to access the variable list and choose the variable to use from it.

For further information about variables, see
Talend Studio

User Guide.

Usage

Usage rule

The tRowGenerator
Editor’s ease of use allows users without any Java knowledge to generate random
data for test purposes.

Defining the schema

First you need to define the structure of data to be generated.

  • Add as many columns to your schema as needed, using the plus (+) button.

  • Type in the names of the columns to be created in the Columns area and select the Key check box if required

  • Make sure you define then the nature of the data contained in the column,
    by selecting the Type in the list.
    According to the type you select, the list of Functions offered will differ. This information is therefore
    compulsory.

tRowGenerator_1.png
  • Some extra information, although not required, might be useful such as
    Length, Precision or Comment. You
    can also hide these columns, by clicking on the Columns drop-down button next to the toolbar, and unchecking
    the relevant entries on the list.

  • In the Function area, you can select the
    predefined routine/function if one of them corresponds to your needs.You can
    also add to this list any routine you stored in the Routine area of the Repository. Or you can type in the function you want to use
    in the Function definition panel. Related
    topic: see
    Talend Studio User Guide
    .

  • Click Refresh to have a preview of the
    data generated.

  • Type in a number of rows to be generated. The more rows to be generated,
    the longer it’ll take to carry out the generation operation.

Defining the function

Select the […] under Function in the Schema definition panel in order to customize the
function parameters.

  • Select the Function parameters tab

  • The Parameter area displays Customized parameter as function name
    (read-only)

tRowGenerator_2.png
  • In the Value area, type in the Java
    function to be used to generate the data specified.

  • Click on the Preview tab and click
    Preview to check out a sample of the
    data generated.

Generating random java data

The following scenario creates a two-component Job, generating 50 rows structured as
follows: a randomly picked-up ID in a 1-to-3 range, a random ascii First Name and Last
Name generation and a random date taken in a defined range.

tRowGenerator_3.png
  • Drop a tRowGenerator and a tLogRow component from the Palette to the design workspace.

  • Right-click tRowGenerator and select
    Row > Main. Drag this main row link onto the tLogRow component and release when the plug symbol
    displays.

  • Double click tRowGenerator to open the
    Editor.

  • Define the fields to be generated.

tRowGenerator_4.png
  • The random ID column is of integer type, the First and Last names are of
    string type and the Date is of date type.

  • In the Function list, select the relevant
    function or set on the three dots for custom function.

  • On the Function parameters tab, define the
    Values to be randomly picked up.

tRowGenerator_5.png
  • First_Name and Last_Name columns are
    to be generated using the getAsciiRandomString function that is predefined in
    the system routines. By default the length defined is 6 characters long. You can
    change this if need be.

  • The Date column calls the predefined getRandomDate
    function. You can edit the parameter values in the Function parameters tab.

  • Set the Number of Rows to be generated to
    50.

  • Click OK to validate the setting.

  • Double click tLogRow to view the Basic
    settings. The default setting is retained for this Job.

  • Press F6 to run the Job.

tRowGenerator_6.png

The 50 rows are generated following the setting defined in the tRowGenerator editor and the output is displayed in the Run console.

tRowGenerator MapReduce properties (deprecated)

These properties are used to configure tRowGenerator running in
the MapReduce Job framework.

The MapReduce
tRowGenerator component belongs to the Misc family.

The component in this framework is available in all subscription-based Talend products with Big Data
and Talend Data Fabric.

The MapReduce framework is deprecated from Talend 7.3 onwards. Use Talend Jobs for Apache Spark to accomplish your integration tasks.

Basic settings

Schema and Edit
schema

A schema is a row description. It defines the number of fields
(columns) to be processed and passed on to the next component. When you create a Spark
Job, avoid the reserved word line when naming the
fields.

Click Edit
schema
to make changes to the schema. If the current schema is of the Repository type, three options are available:

  • View schema: choose this
    option to view the schema only.

  • Change to built-in property:
    choose this option to change the schema to Built-in for local changes.

  • Update repository connection:
    choose this option to change the schema stored in the repository and decide whether
    to propagate the changes to all the Jobs upon completion. If you just want to
    propagate the changes to the current Job, you can select No upon completion and choose this schema metadata
    again in the Repository Content
    window.

 

Built-In: You create and store the schema locally for this component
only.

 

Repository: You have already created the schema and stored it in the
Repository. You can reuse it in various projects and Job designs.

RowGenerator editor

The editor allows you to define the columns and the nature of
data to be generated. You can use predefined routines or type in the function
to be used to generate the data specified.

Note that in a Storm Job, the value -1
in the Number of rows for RowGenerator
field in the RowGenerator editor means
to generate infinite rows of input data.

Advanced settings

tStatCatcher Statistics

Select this check box to collect log data at the component
level.

Global Variables

Global Variables

ERROR_MESSAGE: the error message generated by the
component when an error occurs. This is an After variable and it returns a string. This
variable functions only if the Die on error check box is
cleared, if the component has this check box.

A Flow variable functions during the execution of a component while an After variable
functions after the execution of the component.

To fill up a field or expression with a variable, press Ctrl +
Space
to access the variable list and choose the variable to use from it.

For further information about variables, see
Talend Studio

User Guide.

Usage

Usage rule

The tRowGenerator
Editor’s ease of use allows users without any Map/Reduce knowledge to generate
random data for test purposes.

In a
Talend
Map/Reduce Job, it is used as a start component and requires
a transformation component as output link. The other components used along with it must be
Map/Reduce components, too. They generate native Map/Reduce code that can be executed
directly in Hadoop.

You need to use the Hadoop Configuration tab in the
Run view to define the connection to a given Hadoop
distribution for the whole Job.

This connection is effective on a per-Job basis.

For further information about a
Talend
Map/Reduce Job, see the sections
describing how to create, convert and configure a
Talend
Map/Reduce Job of the

Talend Open Studio for Big Data Getting Started Guide
.

Note that in this documentation, unless otherwise
explicitly stated, a scenario presents only Standard Jobs,
that is to say traditional
Talend
data integration Jobs, and non Map/Reduce Jobs.

Related scenarios

No scenario is available for the Map/Reduce version of this component yet.

tRowGenerator properties for Apache Spark Batch

These properties are used to configure tRowGenerator running in the Spark Batch Job framework.

The Spark Batch
tRowGenerator component belongs to the Misc family.

The component in this framework is available in all subscription-based Talend products with Big Data
and Talend Data Fabric.

Basic settings

Define a storage configuration
component

Select the configuration component to be used to provide the configuration
information for the connection to the target file system such as HDFS.

If you leave this check box clear, the target file system is the local
system.

The configuration component to be used must be present in the same Job.
For example, if you have dropped a tHDFSConfiguration component in the Job, you can select it to write
the result in a given HDFS system.

Schema and Edit
schema

A schema is a row description. It defines the number of fields
(columns) to be processed and passed on to the next component. When you create a Spark
Job, avoid the reserved word line when naming the
fields.

Click Edit
schema
to make changes to the schema. If the current schema is of the Repository type, three options are available:

  • View schema: choose this
    option to view the schema only.

  • Change to built-in property:
    choose this option to change the schema to Built-in for local changes.

  • Update repository connection:
    choose this option to change the schema stored in the repository and decide whether
    to propagate the changes to all the Jobs upon completion. If you just want to
    propagate the changes to the current Job, you can select No upon completion and choose this schema metadata
    again in the Repository Content
    window.

The schema of tRowGenerator does not support the Object type.

 

Built-In: You create and store the schema locally for this component
only.

 

Repository: You have already created the schema and stored it in the
Repository. You can reuse it in various projects and Job designs.

RowGenerator editor

The editor allows you to define the columns and the nature of data to
be generated. You can use predefined routines or type in the function to
be used to generate the data specified.

Usage

Usage rule

This component is used as a start component and requires an output
link..

This component, along with the Spark Batch component Palette it belongs to,
appears only when you are creating a Spark Batch Job.

Note that in this documentation, unless otherwise explicitly stated, a
scenario presents only Standard Jobs, that is to
say traditional
Talend
data integration Jobs.

Spark Connection

In the Spark
Configuration
tab in the Run
view, define the connection to a given Spark cluster for the whole Job. In
addition, since the Job expects its dependent jar files for execution, you must
specify the directory in the file system to which these jar files are
transferred so that Spark can access these files:

  • Yarn mode (Yarn client or Yarn cluster):

    • When using Google Dataproc, specify a bucket in the
      Google Storage staging bucket
      field in the Spark configuration
      tab.

    • When using HDInsight, specify the blob to be used for Job
      deployment in the Windows Azure Storage
      configuration
      area in the Spark
      configuration
      tab.

    • When using Altus, specify the S3 bucket or the Azure
      Data Lake Storage for Job deployment in the Spark
      configuration
      tab.
    • When using Qubole, add a
      tS3Configuration to your Job to write
      your actual business data in the S3 system with Qubole. Without
      tS3Configuration, this business data is
      written in the Qubole HDFS system and destroyed once you shut
      down your cluster.
    • When using on-premise
      distributions, use the configuration component corresponding
      to the file system your cluster is using. Typically, this
      system is HDFS and so use tHDFSConfiguration.

  • Standalone mode: use the
    configuration component corresponding to the file system your cluster is
    using, such as tHDFSConfiguration or
    tS3Configuration.

    If you are using Databricks without any configuration component present
    in your Job, your business data is written directly in DBFS (Databricks
    Filesystem).

This connection is effective on a per-Job basis.

Related scenarios

No scenario is available for the Spark Batch version of this component
yet.

tRowGenerator properties for Apache Spark Streaming

These properties are used to configure tRowGenerator running in
the Spark Streaming Job framework.

The Spark Streaming
tRowGenerator component belongs to the Misc family.

This component is available in Talend Real Time Big Data Platform and Talend Data Fabric.

Basic settings

Schema and Edit
schema

A schema is a row description. It defines the number of fields
(columns) to be processed and passed on to the next component. When you create a Spark
Job, avoid the reserved word line when naming the
fields.

Click Edit
schema
to make changes to the schema. If the current schema is of the Repository type, three options are available:

  • View schema: choose this
    option to view the schema only.

  • Change to built-in property:
    choose this option to change the schema to Built-in for local changes.

  • Update repository connection:
    choose this option to change the schema stored in the repository and decide whether
    to propagate the changes to all the Jobs upon completion. If you just want to
    propagate the changes to the current Job, you can select No upon completion and choose this schema metadata
    again in the Repository Content
    window.

 

Built-In: You create and store the schema locally for this component
only.

 

Repository: You have already created the schema and stored it in the
Repository. You can reuse it in various projects and Job designs.

RowGenerator editor

The editor allows you to define the columns and the nature of
data to be generated. You can use predefined routines or type in the function
to be used to generate the data specified.

The value -1 in the Number of rows for RowGenerator field in the
RowGenerator editor means to generate
infinite rows of input data.

Input repetition interval (ms)

Enter the time interval (in milliseconds) at the end of which
tRowGenerator generates a batch of
data.

Usage

Usage rule

This component is used as a start component and requires an output
link..

This component, along with the Spark Streaming component Palette it belongs to, appears
only when you are creating a Spark Streaming Job.

Note that in this documentation, unless otherwise explicitly stated, a scenario presents
only Standard Jobs, that is to say traditional
Talend
data
integration Jobs.

Spark Connection

In the Spark
Configuration
tab in the Run
view, define the connection to a given Spark cluster for the whole Job. In
addition, since the Job expects its dependent jar files for execution, you must
specify the directory in the file system to which these jar files are
transferred so that Spark can access these files:

  • Yarn mode (Yarn client or Yarn cluster):

    • When using Google Dataproc, specify a bucket in the
      Google Storage staging bucket
      field in the Spark configuration
      tab.

    • When using HDInsight, specify the blob to be used for Job
      deployment in the Windows Azure Storage
      configuration
      area in the Spark
      configuration
      tab.

    • When using Altus, specify the S3 bucket or the Azure
      Data Lake Storage for Job deployment in the Spark
      configuration
      tab.
    • When using Qubole, add a
      tS3Configuration to your Job to write
      your actual business data in the S3 system with Qubole. Without
      tS3Configuration, this business data is
      written in the Qubole HDFS system and destroyed once you shut
      down your cluster.
    • When using on-premise
      distributions, use the configuration component corresponding
      to the file system your cluster is using. Typically, this
      system is HDFS and so use tHDFSConfiguration.

  • Standalone mode: use the
    configuration component corresponding to the file system your cluster is
    using, such as tHDFSConfiguration or
    tS3Configuration.

    If you are using Databricks without any configuration component present
    in your Job, your business data is written directly in DBFS (Databricks
    Filesystem).

This connection is effective on a per-Job basis.

Related scenarios

No scenario is available for the Spark Streaming version of this component
yet.

tRowGenerator Storm properties (deprecated)

These properties are used to configure tRowGenerator running in
the Storm Job framework.

The Storm
tRowGenerator component belongs to the Misc family.

This component is available in Talend Real Time Big Data Platform and Talend Data Fabric.

The Storm framework is deprecated from Talend 7.1 onwards. Use Talend Jobs for Apache Spark Streaming to accomplish your Streaming related tasks.

Basic settings

Schema and Edit
schema

A schema is a row description. It defines the number of fields
(columns) to be processed and passed on to the next component. When you create a Spark
Job, avoid the reserved word line when naming the
fields.

Click Edit
schema
to make changes to the schema. If the current schema is of the Repository type, three options are available:

  • View schema: choose this
    option to view the schema only.

  • Change to built-in property:
    choose this option to change the schema to Built-in for local changes.

  • Update repository connection:
    choose this option to change the schema stored in the repository and decide whether
    to propagate the changes to all the Jobs upon completion. If you just want to
    propagate the changes to the current Job, you can select No upon completion and choose this schema metadata
    again in the Repository Content
    window.

 

Built-In: You create and store the schema locally for this component
only.

 

Repository: You have already created the schema and stored it in the
Repository. You can reuse it in various projects and Job designs.

RowGenerator editor

The editor allows you to define the columns and the nature of
data to be generated. You can use predefined routines or type in the function
to be used to generate the data specified.

Note that in a Storm Job, the value -1
in the Number of rows for RowGenerator
field in the RowGenerator editor means
to generate infinite rows of input data.

Advanced settings

tStatCatcher Statistics

Select this check box to collect log data at the component
level.

Usage

Usage rule

The tRowGenerator
Editor’s ease of use allows users without any Storm knowledge to generate
random data for test purposes.

In a
Talend
Storm Job, it is used as a start component. The other
components used along with it must be Storm components, too. They generate native Storm code
that can be executed directly in a Storm system.

The Storm version does not support the use of the global variables.

You need to use the Storm Configuration tab in the
Run view to define the connection to a given Storm
system for the whole Job.

This connection is effective on a per-Job basis.

For further information about a
Talend
Storm Job, see the sections
describing how to create and configure a
Talend
Storm Job of the
Talend Open Studio for Big Data Getting Started Guide
.

Note that in this documentation, unless otherwise explicitly stated, a scenario presents
only Standard Jobs, that is to say traditional
Talend
data
integration Jobs.

Related scenarios

No scenario is available for the Storm version of this component
yet.


Document get from Talend https://help.talend.com
Thank you for watching.
Subscribe
Notify of
guest
0 Comments
Inline Feedbacks
View all comments
0
Would love your thoughts, please comment.x
()
x