tWriteAvroFields properties for Apache Spark Structured Streaming
Last updated: 9/30/2026Use these properties to configure tWriteAvroFields running in the Spark Structured Streaming Job framework.
The Spark Structured Streaming tWriteAvroFields component belongs to the Processing family.
The streaming version of this component is available in Talend Real-Time Big Data Platform and in Talend Data Fabric.
Basic settings
| Properties | Description |
|---|---|
| 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. The schema of this component is read-only. You can click Edit schema to view the schema. This read-only schema of tWriteAvroFields receives data as an entire object from the schema of its input component without caring about what this input schema should look like and serializes the incoming object into Avro binaries. That is to say, it does not require the input flow to have the identical schema. For example, an input schema composed of a user column and an age column can be directly serialized. Note that the supported data types by this component are listed in its Basic settings view. |
| Use data column as partition key | Select this check box to use a data column as the partition key when writing Avro data. |
Usage
| Usage guidance | Description |
|---|---|
| Usage rule |
This component is used as an intermediate step. This component, along with the Spark Structured Streaming component Palette it belongs to, appears only when you are creating a Spark Structured 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 |
You need to use the Structured Streaming Configuration tab in the Run view to define the connection to a Spark cluster for the whole Job. This connection is effective on a per-Job basis. |