tAvroOutput
the data into Avro format files in a given distributed file system.
Depending on the Talend solution you
are using, this component can be used in one, some or all of the following Job
frameworks:
-
MapReduce: see tAvroOutput MapReduce properties.
The component in this framework is available only if you have subscribed to one
of the
Talend
solutions with Big Data. -
Spark Batch: see tAvroOutput properties for Apache Spark Batch
The component in this framework is available only if you have subscribed to one
of the
Talend
solutions with Big Data. -
Spark Streaming: see tAvroOutput properties for Apache Spark Streaming
The component in this framework is available only if you have subscribed to Talend Real-time Big Data Platform or Talend Data
Fabric.
tAvroOutput MapReduce properties
These properties are used to configure tAvroOutput running in the MapReduce Job framework.
The MapReduce
tAvroOutput component belongs to the MapReduce family.
The component in this framework is available only if you have subscribed to one
of the
Talend
solutions with Big Data.
Basic settings
Property type |
Either Built-In or Repository. |
Built-In: No property data stored centrally. |
|
Repository: Select the repository file where the The properties are stored centrally under the Hadoop The fields that come after are pre-filled in using the fetched For further information about the Hadoop |
|
Schema and Edit |
A schema is a row description. It defines the number of fields (columns) to Click Edit schema to make changes to the schema.
|
Built-In: You create and store the |
|
Repository: You have already created |
|
Folder |
Browse to, or enter the path pointing to the data to be used in the file system. This path must point to a folder rather than a file, because a Note that you need |
Action |
Select an operation for writing data:
Create: Creates a file and write
Overwrite: Overwrites the file |
Compression |
Select the Compress data blocks Hadoop provides different compression formats that help reduce the space needed for |
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 A Flow variable functions during the execution of a component while an After variable To fill up a field or expression with a variable, press Ctrl + For further information about variables, see |
Usage
Usage rule |
In a Once a Map/Reduce Job is opened in the workspace, tAvroOutput as well as the MapReduce Note that in this documentation, unless otherwise |
Hadoop Connection |
You need to use the Hadoop Configuration tab in the This connection is effective on a per-Job basis. |
Related scenario
-
Related topic, see Scenario: Filtering Avro format employee data.
tAvroOutput properties for Apache Spark Batch
These properties are used to configure tAvroOutput running in the Spark Batch Job framework.
The Spark Batch
tAvroOutput component belongs to the File family.
The component in this framework is available only if you have subscribed to one
of the
Talend
solutions with Big Data.
Basic settings
Define a storage configuration |
Select the configuration component to be used to provide the configuration If you leave this check box clear, the target file system is the local The configuration component to be used must be present in the same Job. For |
Property type |
Either Built-In or Repository. |
Built-In: No property data stored centrally. |
|
Repository: Select the repository file where the The properties are stored centrally under the Hadoop The fields that come after are pre-filled in using the fetched For further information about the Hadoop |
|
Schema and Edit |
A schema is a row description. It defines the number of fields (columns) to Click Edit schema to make changes to the schema.
|
Built-In: You create and store the |
|
Repository: You have already created |
|
Folder |
Browse to, or enter the path pointing to the data to be used in the file system. This path must point to a folder rather than a file, because a The button for browsing does not work with the Spark Local mode; if you are using the Spark Yarn or the Spark Standalone mode, |
Action |
Select an operation for writing data:
Create: Creates a file and write
Overwrite: Overwrites the file |
Compression |
Select the Compress data blocks Hadoop provides different compression formats that help reduce the space needed for |
Advanced settings
Use output schema compatible with |
Select this check box to define a hierarchical key/value schema for the Avro file to be For this purpose, you need to specify the columns of the output data to be used as key For example, the following data is an Avro record written with this key/value structure:
|
Usage
Usage rule |
This component is used as an end component and requires an input link. This component, along with the Spark Batch component Palette it belongs to, appears only Note that in this documentation, unless otherwise |
Spark Connection |
You need to use the Spark Configuration tab in
the Run view to 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:
This connection is effective on a per-Job basis. |
Related scenarios
No scenario is available for the Spark Batch version of this component
yet.
tAvroOutput properties for Apache Spark Streaming
These properties are used to configure tAvroOutput running in the Spark Streaming Job framework.
The Spark Streaming
tAvroOutput component belongs to the File family.
The component in this framework is available only if you have subscribed to Talend Real-time Big Data Platform or Talend Data
Fabric.
Basic settings
Define a storage configuration |
Select the configuration component to be used to provide the configuration If you leave this check box clear, the target file system is the local The configuration component to be used must be present in the same Job. For |
Property type |
Either Built-In or Repository. |
Built-In: No property data stored centrally. |
|
Repository: Select the repository file where the The properties are stored centrally under the Hadoop The fields that come after are pre-filled in using the fetched For further information about the Hadoop |
|
Schema and Edit |
A schema is a row description. It defines the number of fields (columns) to Click Edit schema to make changes to the schema.
|
Built-In: You create and store the |
|
Repository: You have already created |
|
Folder |
Browse to, or enter the path pointing to the data to be used in the file system. This path must point to a folder rather than a file, because a The button for browsing does not work with the Spark Local mode; if you are using the Spark Yarn or the Spark Standalone mode, |
Action |
Select an operation for writing data:
Create: Creates a file and write
Overwrite: Overwrites the file |
Compression |
Select the Compress data blocks Hadoop provides different compression formats that help reduce the space needed for |
Usage
Usage rule |
This component is used as an end component and requires an input link. This component, along with the Spark Streaming component Palette it belongs to, appears Note that in this documentation, unless otherwise explicitly stated, a scenario presents |
Spark Connection |
You need to use the Spark Configuration tab in
the Run view to 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:
This connection is effective on a per-Job basis. |
Related scenarios
No scenario is available for the Spark Streaming version of this component
yet.