Hi, does anyone know of working transformation con...
# general
p
Hi, does anyone know of working transformation config to convert array of payloads using Groovy function for REALTIME ingestion table. I was referring this doc To elaborate my use-case, sample JSON payload received at Kafka Topic T :
Copy code
[
  {
    "Key1": "Value1",
    "Key2": "Value2"
  },
  {
    "Key3": "Value3",
    "Key4": "Value4"
  }
]
Pinot table config uses this Kafka topic T in its stream configs and I would like each object in this array to be ingested to different rows in a Pinot (UPSERT table).
@Mayank @Jackie
j
Transform itself is not enough since you want to flatten the record
p
Ok thanks @Jackie - my use-case was mostly to split JSON into multiple records.