AsapSource reads this data (records) and passes it on to JDBCLookupPipe, which modifies the records according to data available and reference data from the database tables. JDBCLookupPipe then passes that data to FileSink, which then writes the records to file.
- Table "test1" contains data "col1='AttributeKey'" and "col2='replaceValue1'". 'KeyDbCol1' is col1 in the props file, therefore, col1 column contains attribute keys.
- Theses attribute keys are present in the incoming record column 'textfield'.
- To replace the 'charfield' column value of a record to 'replaceValue1', then include 'AttributeKey' as a value in 'textfield' column of a record
See the
esp_insert.txt file for more details. Records that do not have 'AttributeKey' as the 'textfield' column value do not get modified.