Setting up subJob 3 - Cloud - 8.0

Neo4j
Version
Cloud
8.0
Language
English
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
Data Governance > Third-party systems > NoSQL components > Neo4j components
Data Quality and Preparation > Third-party systems > NoSQL components > Neo4j components
Design and Development > Third-party systems > NoSQL components > Neo4j components

Procedure

  1. Double-click tFixedFlowInput_2 to open its Basic settings view and do the following:
    1. Open the schema editor by clicking the [...] button next to Edit schema and add a column in the schema editor: name, type String.
    2. Enter 5 in the Number of rows field.
    3. Select Use Inline Content(delimited file) and enter the following in the Content field. 
      FirstBank
Citizens
Wells Fargo
    4. Leave the other options as they are.

    This component generates 15 records. Each of the record has only one field: name.

  2. Double-click tMap_2 to open its map editor and do the following:
    1. Add two rows in the out2 table with the Column of accntid, and balance, setting the Type to Integer for the two columns.
      You can add a row in the table by clicking the plus button under the table.
    2. Map the name column in the row2 section to the name column in the out2 section.
      You can map a column by dragging and dropping the source column in the row2 section to the Expression field of the target column in the out2 section.
    3. Enter Numeric.random(0,14) in the Expression field of the accntid column.
    4. Enter Numeric.random(1000,100000) in the Expression field of the balance column.
    5. Click OK to close map editor.

    This component receives name information from the tFixedFlowInput_2 component and adds extra information for creating nodes in the Neo4jv4 database, including accntid and balance.

  3. Double-click tNeo4jv4Output_2 to open its Basic settings view and do the following:
    1. Select the Use an existing connection option and select tNeo4jv4Connection_1 from the Component List drop-down list.
    2. Click the Sync column button to make sure the component has the same columns as the output of tMap_1.
    3. Select Send data as list and enter rows in the Data list name.
      This step specifies to treat the input data as a list and assign a name to the list (that is, rows), so that the list can be referenced.
    4. Enter the following clauses in the Query field. 
      UNWIND $rows as row
MERGE (a:Account:UpdateMe {id: row.accntid} )
SET a.name = row.name, a.balance = row.balance
    5. Leave the other options as they are.

    This component creates nodes and sets properties for the nodes using the data received. For more information about the UNWIND clause, see UNWIND; for more information about the MERGE clause, see MERGE.