Apache Pinot

Hi team, I have a question and don’t know how to solve it. How can I extract numOfStas.Policy in Kafka message and save it to a Pinot table field? When I use *transformFunction*, it doesn’t work.
{
        “columnName”: “stas_policy”,
        “transformFunction”: “jsonPathString(stats, ‘$.text_body.fields.numOfStas.Policy’)”
      }
*And  a sample Kafka message is like this:*
{
  “name”: “telemetry_signal_gfw_api_usage”,
  “stats”: {
    “text_body”: {
      “fields”: {
        “numOfStas”: 0,
        “numOfStas.Policy”: 21
      }
    }
  }
}

<https://dev.startree.ai/docs/pinot/recipes/json-unnest-rename-fields> take a look at this to see if it helps

I think the tricky thing is that `text_body` is an array

Hi, thanks, I’m trying on <https://jsonpath.herokuapp.com/>. And I think I just found how to extract it. $.text_body.fields[“numOfStas.Policy”] will work.

image.png

that makes sense - I guess the way it was before it didn't realise that the `.` was part of the property name