# tAggregateRow properties for Apache Spark Batch

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

The Spark Batch tAggregateRow component belongs to the Processing family.

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

## Basic settings

| Schema and Edit<br>Schema | A schema is a row description. It defines the number of fields<br>(columns) to be processed and passed on to the next component. When you create a Spark<br>Job, avoid the reserved word line when naming the<br>fields.<br><br>Click Edit<br>schema to make changes to the schema. If the current schema is of the Repository type, three options are available:<br><br><ul> <li> <p> <span>View schema</span>: choose this                option to view the schema only.</p> </li> <li> <p> <span>Change to built-in property</span>:                choose this option to change the schema to <span>Built-in</span> for local changes.</p> </li> <li> <p> <span>Update repository connection</span>:                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 <span>No</span> upon completion and choose this schema metadata                again in the <span>Repository Content</span>                window.</p> </li> </ul><br><br>Information noteTip: By default, when Spark aggregates BigDecimal, the<br>precision and scale are set at the maximum values of the data type.<br>You can change the scale and the precision for BigDecimal in the<br>corresponding columns of the schema. |
| --- | --- |
|  | Built-In: You create and store the schema locally for this component<br>only. |
|  | Repository: You have already created the schema and stored it in the<br>Repository. You can reuse it in various projects and Job designs. |
| Group by | Define the aggregation sets, the values of which will be used for<br>calculations. |
|  | Output Column: Select the column<br>label in the list offered based on the schema structure you defined. You<br>can add as many output columns as you wish to make more precise<br>aggregations.<br><br>Ex: Select Country to calculate an average of values for each country<br>of a list or select Country and Region if you want to compare one<br>country's regions with another country' regions. |
|  | Input Column: Match the input column<br>label with your output columns, in case the output label of the<br>aggregation set needs to be different. |
| Operations | Select the type of operation along with the value to use for the<br>calculation and the output field. |
|  | Output Column: Select the destination<br>field in the list. |
|  | Function: Select the operator among:<br><br><ul> <li> <p> <span>count</span>: calculates the number of rows</p> </li> <li> <p> <span>count (distinct)</span>: counts the number of the distinct rows</p> </li> <li> <p> <span>min</span>: selects the minimum value</p> </li> <li> <p> <span>max</span>: selects the maximum value</p> </li> <li> <p> <span>avg</span>: calculates the average</p> </li> <li> <p> <span>sum</span>: calculates the sum</p> </li> <li> <span>population standard deviation</span>: calculates the                                spread of a data distribution. Use this function if the data to be                                calculated is considered a population on its own. This calculation                                supports 39 decimal places.</li> <li> <span>sample                                    standard deviation</span>: calculates the spread of a data                                distribution. Use this function if the data to be calculated is                                considered a sample from a larger population. This calculation                                supports 39 decimal places.</li> </ul><br><br>Some functions that are available in a traditional ETL Job, such as first or last, are not available in Spark Jobs because these functions does not make sense in a distributed environment. |
|  | Input column: Select the input column<br>from which the values are taken to be aggregated. |
|  | Ignore null values: Select the check<br>boxes corresponding to the names of the columns for which you want the<br>NULL value to be ignored. |

## Advanced settings

| Use financial precision, this is the max precision for "sum"<br>and "avg" operations, checked option heaps more memory and slower<br>than unchecked. | Select this check box to use a financial precision. This is a max<br>precision but consumes more memory and slows the processing.<br><br>Information noteWarning:<br><br><br>*We advise you to use the BigDecimal type for the output in<br>order to obtain precise results.* |
| --- | --- |
| Check type overflow (slower) | Checks the type of data to ensure that the Job doesn't crash. |
| Check ULP (Unit in the Last Place), ensure that a value will<br>be incremented or decremented correctly, only float and double<br>types. (slower) | Select this check box to ensure the most precise results possible for<br>the Float and Double types. |

## Usage

| **Usage rule** | This component is used as an intermediate step.<br><br>This component, along with the Spark Batch component Palette it belongs to,<br>appears only when you are creating a Spark Batch Job.<br><br>Note that in this documentation, unless otherwise explicitly stated, a<br>scenario presents only Standard Jobs, that is to<br>say traditional<br>Talend<br>data integration Jobs. |
| --- | --- |
| Spark Connection | In the Spark<br>Configuration tab in the Run<br>view, define the connection to a given Spark cluster for the whole Job. In<br>addition, since the Job expects its dependent jar files for execution, you must<br>specify the directory in the file system to which these jar files are<br>transferred so that Spark can access these files:<br><br><ul> <li> <div> <span>Yarn mode</span> (Yarn client or Yarn cluster):<ul> <li> <p>When using Google Dataproc, specify a bucket in the                                            <span>Google Storage staging bucket</span>                                        field in the <span>Spark configuration</span>                                        tab.</p> </li> <li> <p>When using HDInsight, specify the blob to be used for Job                                        deployment in the <span>Windows Azure Storage                                            configuration</span> area in the <span>Spark                                            configuration</span> tab.</p> </li> <li>When using Altus, specify the S3 bucket or the Azure                                    Data Lake Storage for Job deployment in the <span>Spark                                        configuration</span> tab.</li> <li>When using Qubole, add a                                        <span>tS3Configuration</span> to your Job to write                                    your actual business data in the S3 system with Qubole. Without                                        <span>tS3Configuration</span>, this business data is                                    written in the Qubole HDFS system and destroyed once you shut                                    down your cluster.</li> <li> <p>When using on-premises distributions, use the configuration component                                        corresponding to the file system your cluster is using.                                        Typically, this system is HDFS and so use <a href="https://help.qlik.com/talend/r/en-US/7.3/components/hdfs/thdfsconfiguration">tHDFSConfiguration</a>.</p> </li> </ul> </div> </li> <li> <p> <span>Standalone mode</span>: use the                            configuration component corresponding to the file system your cluster is                            using, such as <a href="https://help.qlik.com/talend/r/en-US/7.3/components/hdfs/thdfsconfiguration-properties-for-apache-spark-batch">tHDFSConfiguration Apache Spark Batch</a> or <a href="https://help.qlik.com/talend/r/en-US/7.3/components/amazon-s3/ts3configuration-properties-for-apache-spark-batch">tS3Configuration Apache Spark Batch</a>.</p> <p>If you are using Databricks without any configuration component present                            in your Job, your business data is written directly in DBFS (Databricks                            Filesystem).</p> </li> </ul><br><br>This connection is effective on a per-Job basis. |