In this step, we will configure the second Job, B_HCatalog_Load, to upload the access log file to the Hadoop
system.
Procedure
Double-click the tApacheLogInput
component to open its Basic settings
view, and specify the path to the access log file to be uploaded in the
File Name field.
In this example,
we store the log file access_log in
the directory C:/Talend/BigData.
Double-click the tFilterRow component
to open its Basic settings view.
From the Logical operator used to combine
conditions list box, select AND.
Click the [+] button to add a line in
the Filter configuration table, and set
filter parameters to send records that contain the code of "301" to the
Reject flow and pass the rest records on to the Filter flow:
In the InputColumn field,
select the code column of the
schema.
In the Operator field, select
Not equal to.
In the Value field, enter
301.
Double-click the tHCatalogOutput
component to open its Basic settings
view.
Click the Property Type list box and select Repository, and then click the [...] button to open the Repository Content dialog box to use a centralized HCatalog connection.
Select the
HCatalog connection defined for connecting to the HCatalog database and
click OK.
All the connection details
are automatically filled in the respective fields.
Click the [...] button to verify that
the schema has been properly propagated from the preceding component. If
needed, click Sync columns to retrieve
the schema.
From the Action list, select
Create to create the file or
Overwrite if the file already
exists.
In the Partition field, enter the
partition name-value pair between double quotation marks, ipaddresses='192.168.1.15' in this
example.
In the File location field, enter the
path where the data will be save, /user/hdp/weblog/access_log in this example.
Double-click the tLogRow component to
open its Basic settings view, and
select the Vertical option to display
each row of the output content in a list for better readability.
Upon completion of the component settings, press Ctrl+S to save your Job configurations.
Did this page help you?
If you find any issues with this page or its content – a typo, a missing step, or a technical error – please let us know!