Is there an easy way to transform the incoming rec...
# general
d
Is there an easy way to transform the incoming records by specifying a function in the configs? Just checking.
k
What kind of function are you looking to apply
schema supports a field called transformFunction
d
I currently have a logging json that I'm passing into Kinesis. It currently logs and I was going to have Pinot ingest the same thing from Kinesis. Small transformations like take an enum value and convert it to separate counts. E.g. EventType=CLICK => impressions = 0, clicks= 1.
k
got it.
will eventType be part of the data in Pinot?
d
I was planning on splitting it to become separate metrics.
This is mostly for quick development. Longer-term, I'll probably have separate definitions for logging and pinot.
k
we feature is not yet ready
by the way, you can write your own custom record reader achieve this for now.
d
True
I figured doing that would make it a little more complex to deploy and probably have a similar complexity to other solutions (e.g. a lambda in Kinesis to transform the data).
k
yes, its not generic.
you dont want to write one custom reader for every table.