Error in Snowflake - Select Snap
Hello,
I have a parent and child pipeline where the parent pipeline sends some venue details to child pipeline. Based on the venue details, the child pipeline calls a REST GET to acquire data from ...
Forum Discussion
Thank you @tstack for the reply, I need to merge with $input1_shoppingHistoryList.shoppingHistory where each element in $shoppingHistoryList corresponds to an element in $input1_shoppingHistoryList but, the remaining fields in ‘$shoppingHistoryList.shoppingHistory’ should not be changed.
You can do this with the expression language inside of a Mapper. For merging the arrays, you can use the sl.zip() function, like so:
sl.zip($shoppingHistoryList.shoppingHistory, $input1_shoppingHistoryList.shoppingHistory)
The result of that expression will be an array of pairs containing the element from the first array and the corresponding element from the second array. Once they are grouped together, you can use a map() method on the array to iterate over the pairs and then use extend() method to update the properties in the element from the first array with properties from the element in the second:
sl.zip($shoppingHistoryList.shoppingHistory, $input1_shoppingHistoryList.shoppingHistory).map(x => x[0].extend(x[1]))
Here’s an example pipeline that does this mapping:
ReplaceFields_2018_12_16.slp (5.7 KB)
Thank you @bojanvelevski , perfect it is working as expected.
Thank you @kkishore, can you please mark @bojanvelevski’s suggestion as a Solution so that anybody looking at this thread in the future can refer to the solution directly?
