Объедините Json Rows, используя Jolt Nifi Spec - PullRequest
0 голосов
/ 29 октября 2019

Ввод:

[{
    "Store_id": "store_0",
    "Item_id": "item_0",
    "Quantity": "26",
    "Date": "2019-05-01",

}, {
    "Store_id": "store_0",
    "Item_id": "item_0",
    "Quantity": "17",
    "Date": "2019-05-02"
}, {
    "Store_id": "store_0",
    "Item_id": "item_1",
    "Quantity": "47",
    "Date": "2019-05-01",
    "CREATED_DT": "2019-10-09 20:45:47.0",
    "CREATED_BY": "di_user"
}]

Требуется вывод:

[order: {
    "Store_id": "store_0",
    "Date": "2019-05-01"
    items:[
          {item: item_0 , Quantity:26}]},
{
    "Store_id": "store_0",
    "Date": "2019-05-02"
    items:[
          {item: item_0 , Quantity:17}]}

1 Ответ

0 голосов
/ 30 октября 2019

Если я правильно прочитал ваш вывод, ниже спецификации должны работать:

[
  {
    "operation": "shift",
    "spec": {
      "*": {
        "Store_id": "order[&1].Store_id",
        "Date": "order[&1].Date",
        "Item_id": "order[&1].items[#].item",
        "Quantity": "order[&1].items[#].Quantity"
      }
    }
  }
]
...