How do I use Jolt to json array to nested json?

Question

Am new to nifi(1.14) and using JOLTTransform processor to transfer the input json (flatten) to nested json. I could not able to fix with the JOLT Schema. kindly help me on this.

The input JSON is :

[
  {
    "executionTime": "2244",
    "processorId": "3ef03f9c-b42c-4c4e-9d5f-d14878bb2c84",
    "filename": "Trading",
    "processStartTime": "2021-07-26 16:31:19",
    "processSQL": "TradingDetails.sql",
    "executionFetchTime": "2049",
    "sourceCountValue": "5076",
    "startTime": "1627297279651",
    "processGroupName": "Trading"
  },
  {
    "ProcessEndTime": "2021-07-26 16:31:29",
    "completedTime": "1627297289412",
    "processDuration": "0",
    "destCountValue": "5076",
    "tableName": "TRADINGDETAILS"
  },
  {
    "ProcessEndTime": "2021-07-26 16:31:29",
    "completedTime": "1627297289412",
    "processDuration": "0",
    "destCountValue": "5076",
    "tableName": "CUSTTRADINGDETAILS"
  }
]

and the expected JSON output is

{
  "Trading": {
    "Source": {
      "executionTime": "2244",
      "processorId": "3ef03f9c-b42c-4c4e-9d5f-d14878bb2c84",
      "filename": "Trading",
      "processStartTime": "2021-07-26 16:31:19",
      "processSQL": "TradingDetails.sql",
      "executionFetchTime": "2049",
      "sourceCountValue": "5076",
      "startTime": "1627297279651",
      "processGroupName": "Trading"
    },
    "Destination": {
      "TRADINGDETAILS": {
        "ProcessEndTime": "2021-07-26 16:31:29",
        "completedTime": "1627297289412",
        "processDuration": "10",
        "destCountValue": "5076",
        "tableName": "TRADINGDETAILS"
      },
      "CUSTTRADINGDETAILS": {
        "ProcessEndTime": "2021-07-26 16:31:29",
        "completedTime": "1627297289412",
        "processDuration": "10",
        "destCountValue": "5076",
        "tableName": "CUSTTRADINGDETAILS"
      }
    }
  }
}

Thanks in Advance.

Barbaros Özhan · Accepted Answer · 2021-07-28 11:52:37Z

1

You can use successive shift transformations; enumarate the keys of the objects within the first one, and then rename them while nesting each under the related keys such as

[
  {
    "operation": "shift",
    "spec": {
      "*": "&"
    }
  },
  {
    "operation": "shift",
    "spec": {
      "0": "Trading.Source",
      "*": "Trading.Destination.@(0,tableName)"
    }
  }
]

answered Jul 28, 2021 at 11:52

Barbaros Özhan

65.9k11 gold badges36 silver badges64 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How do I use Jolt to json array to nested json?

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related