Extracting information from the message - 7.1

Java custom code for Storm

author
Talend Documentation Team
EnrichVersion
Cloud
7.1
EnrichProdName
Talend Data Fabric
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
task
Data Governance > Third-party systems > Custom code components (Integration) > Java custom code component for Storm
Data Quality and Preparation > Third-party systems > Custom code components (Integration) > Java custom code component for Storm
Design and Development > Third-party systems > Custom code components (Integration) > Java custom code component for Storm
EnrichPlatform
Talend Studio

Procedure

  1. Double-click tJavaStorm to open its Component view.
  2. Click the [...] button next to Edit schema to open the schema editor.
  3. On the output side (right), click the [+] button three times to add three rows and in the Column column, rename them to firstname, gender and activity, respectively. These columns correspond to the information you can extract from the sample message.
  4. Click OK to validate these changes and accept the propagation prompted by the pop-up dialog box.
  5. In the Bolt code area, enter the main method of the bolt to be executed. In this scenario, the code is as follows: String[] tokens = input.get_str().split("\\|"); collector.emit(new Values( tokens[0], tokens[1], tokens[2] ));