I could really use some help. I have flattened documents and for each distinct product-id value, I wish to create an array list of the variants that belong in the product-idโs family. My desired results should look something like this, but Iโm not sure how to get there.
{
"masterproducts": [
{
"product-id": "1",
"variants": [
{
"variant": "988221"
},
{
"variant": "988331"
}]
},
{
"product-id": "1001",
"variants": [
{
"variant": "013356"
},
{
"variant": "933542"
},
{
"variant": "952005"
}]
},
{
"product-id": "1003",
"variants": [
{
"variant": "777100"
}]
}
]
}
Here's what I have so far.
My pipeline:
Output data from the sort snap. Sorting by product-id, variant.
What my GroupBy snap looks like:
Using Json generator I used this array of flattened docs:
from there I sort on product-id using sort snap,
then I groupBy product-id into a field called โgroupโ:
Finally in the mapper I use this expression:
which generates an array of docs where each doc has โproduct-idโ: [array of variants]:
If you need the output to look EXACTLY like you described you can use this expression instead of the one above: { โproduct-idโ : $group[0][โproduct-idโ],โvariantsโ :$group.reduce((accum, curval) => accum.concat([curval[โvariantโ]]), )}
which will generate output exactly as you described: [{โproduct-idโ:โ1001โ,โvariantsโ:[โ777101โ,โ777100โ]},{โproduct-idโ:โ1002โ,โvariantsโ:[โ777102โ,โ777103โ,โ777104โ,โ777105โ]}]
Let me know if this answers your problem.
