# tFileInputPositional properties for Apache Spark Streaming (deprecated)

Availability-note[Deprecated](https://help.talend.com/r/en-US/Cloud/labels-on-talend-help-center/availability-deprecated)

This content is deprecated.

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

Information noteDeprecation: Spark Streaming is deprecated beginning with the R2026-09 release. Use Spark Structured Streaming instead.

The Spark Streaming tFileInputPositional component belongs to the File family.

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

## Basic settings

| Properties | Description |
| --- | --- |
| Define a storage configuration<br>component | Select the configuration component to be used to provide the configuration<br>information for the connection to the target file system such as HDFS.<br><br>If you leave this check box clear, the target file system is the local<br>system.<br><br>The configuration component to be used must be present in the same Job.<br>For example, if you have dropped a tHDFSConfiguration component in the Job, you can select it to write<br>the result in a given HDFS system. |
| Property type | <ul> <li> <p>Either <span>Built-In</span> or <span>Repository</span>. </p> </li> <li> <p> <span>Built-In</span>: No property data stored centrally.</p> </li> <li> <p> <span>Repository</span>: Select the repository file where the            properties are stored.</p> <p>The properties are stored centrally under the <span>Hadoop                Cluster</span> node of the <span>Repository</span>            tree.</p> <p>The fields that come after are pre-filled in using the fetched                data.</p> <p>For more information about the <span>Hadoop            Cluster</span> node, see <a href="https://help.qlik.com/talend/r/en-US/8.0/studio-user-guide/managing-hadoop-metadata" target="_blank">Managing Hadoop connection metadata</a>.</p> </li> </ul> |
| Schema and Edit<br>Schema | <ul> <li> <p>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 <kbd>line</kbd> when naming the            fields.</p> <p>Click <span>Edit schema</span> to make changes to                  the schema. If you make changes, the schema automatically becomes built-in. </p> </li> <li> <p> <span>Built-In</span>: You create and store the schema locally for this component                only.</p> </li> <li> <p> <span>Repository</span>: You have already created the schema and stored it in the                Repository. You can reuse it in various projects and Job designs.</p> </li> </ul> |
| Folder/File | Browse to, or enter the path pointing to the data to be used in the file system.<br><br>If the path you set points to a folder, this component will<br>read all of the files stored in that folder, for example,<br>/user/talend/in; if sub-folders exist, the sub-folders are automatically<br>ignored unless you define the property<br>spark.hadoop.mapreduce.input.fileinputformat.input.dir.recursive to be<br>true in the Advanced properties table in the<br>Spark configuration tab.<br><br><ul> <li>Depending on the filesystem to be used, properly configure the corresponding          configuration component placed in your Job, for example, a            <span>tHDFSConfiguration</span> component for HDFS, a            <span>tS3Configuration</span> component for S3 and a            <span>tAzureFSConfiguration</span> for Azure Storage and Azure Data Lake          Storage.</li> </ul><br><br>If you want to specify more than one files or directories in this<br>field, separate each path using a comma (,).<br><br>If the file to be read is a compressed one, enter the file name<br>with its extension; then tFileInputPositional automatically decompresses it<br>at runtime. The supported compression formats and their<br>corresponding extensions are:<br><br><ul> <li> <p>DEFLATE: <em>*.deflate</em> </p> </li> <li> <p>gzip: <em>*.gz</em> </p> </li> <li> <p>bzip2: <em>*.bz2</em> </p> </li> <li> <p>LZO: <em>*.lzo</em> </p> </li> </ul><br><br>The button for browsing does not work with the Spark Local mode; if you are using the other Spark Yarn modes that Talend Studio<br>supports with your distribution, ensure that you have properly configured the connection<br>in a configuration component in the same Job. Use the configuration component depending<br>on the filesystem to be used. |
| Die on error | Select the checkbox to stop the execution of the Job when an error<br>occurs. |
| Row separator | The separator used to identify the end of a row. |
| Customize | Select this check box to customize the data format of the<br>positional file and define the table columns:<br><br><br>Column: Select the column you<br>want to customize.<br><br><br>Size: Enter the column<br>size.<br><br><br>Padding char: Enter, between double quotation marks,<br>the padding charater you need to remove from the field. A space by<br>default.<br><br><br>Alignment: Select the appropriate<br>alignment parameter. |
| Pattern | Enter between double quotes the length values separated by commas, interpreted as a<br>string. Make sure the values entered in this field are consistent<br>with the schema defined. |
| Header | Enter the number of rows to be skipped in the beginning of file.<br><br>For example, enter *0* to ignore<br>no rows for the data without header and set *1* for the data with header at the first row. |
| Skip empty rows | Select this checkbox to skip the empty rows. |

## Advanced settings

| Properties | Description |
| --- | --- |
| Set minimum partitions | Select this check box to control the number of partitions to be created from the input<br>data over the default partitioning behavior of Spark.<br><br>In the displayed field, enter, without quotation marks, the minimum number of partitions<br>you want to obtain.<br><br>When you want to control the partition number, you can generally set at least as many partitions as<br>the number of executors for parallelism, while bearing in mind the available memory and the<br>data transfer pressure on your network. |
| Custom Encoding | You may encounter encoding issues when you process the stored data. In that<br>situation, select this check box to display the Encoding list.<br><br>Select the encoding from the list or select Custom and define it manually. |
| Advanced separator (for number) | Select this check box to change the separator used for numbers. By default, the thousands separator is a comma (*,*) and the decimal separator is a period (*.*). |
| Trim columns | Select this check box to remove the leading and trailing whitespaces from all<br>columns. When this check box is cleared, the Check column to<br>trim table is displayed, which lets you select particular columns to<br>trim. |

## Usage

| Usage guidance | Description |
| --- | --- |
| **Usage rule** | This component is used as a start component and requires an output link.<br><br>This component is only used to provide the lookup flow (the right side of a join<br>operation) to the main flow of a tMap component. In this<br>situation, the lookup model used by this tMap must be<br>Load once.<br><br>This component, along with the Spark Streaming component Palette it belongs to, appears<br>only when you are creating a Spark Streaming Job.<br><br>Note that in this documentation, unless otherwise explicitly stated, a scenario presents<br>only Standard Jobs, that is to say traditional<br>Talend<br>data<br>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> <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/8.0/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/8.0/components/hdfs/thdfsconfiguration-properties-for-apache-spark-batch">tHDFSConfiguration Apache Spark Batch</a> or <a href="https://help.qlik.com/talend/r/en-US/8.0/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. |