tFileStreamInputJSON
database table.
tFileStreamInputJSON properties for Apache Spark Streaming
These properties are used to configure tFileStreamInputJSON running in the Spark Streaming Job framework.
The Spark Streaming
tFileStreamInputJSON component belongs to the File family.
The streaming version of this component is available in Talend Real Time Big Data Platform and in
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. |
Property type |
Either Built-In or Repository. |
 |
Built-In: No property data stored centrally. |
 |
Repository: Select the repository file where the The fields that come after are pre-filled in using the fetched For further information about the File |
Schema et Edit |
A schema is a row description. It defines the number of fields Click Edit
|
 |
Built-In: You create and store the schema locally for this component |
 |
Repository: You have already created the schema and stored it in the |
Read by |
Select a way of extracting the JSON data in the file.
|
Folder/File |
Browse to, or enter the path pointing to the data to be used in the file system. If the path you entered points to a folder, all files stored in If the file to be read is a compressed one, enter the file name
The button for browsing does not work with the Spark tHDFSConfiguration |
Die on error |
Select the check box to stop the execution of the Job when an error |
Loop Jsonpath query |
Enter the path pointing to the node within the JSON field, on which the loop is Note if you have selected Xpath from the Read |
Mapping |
Complete this table to map the columns defined in the schema to the
|
Advanced settings
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 (.). |
Encoding |
You may encounter encoding issues when you process the stored data. In that Select the encoding from the list or select Custom and define it manually. |
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 Note that in this documentation, unless otherwise explicitly stated, a scenario presents |
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:
This connection is effective on a per-Job basis. |
Related scenarios
No scenario is available for the Spark Streaming version of this component
yet.