Hi,
I have data coming from a postgres query, and the embedded schema includes
entries like:

[{"type":"bytes", "logicalType":"decimal", "precision":10, "scale":0},
"null"]

I'm having trouble dealing with these in a groovy script. Other uses of the
same script with different databases have more standard numeric
representations. I don't want to disable the use avro logical types part of
the sql processor because I have timestamps and would like to keep them as
they are.

Is there a transparent(ish) way to deal with both numeric types in the
groovy script so I can use the same script in both? Is there a way of using
the updaterecordprocessor and the expression language to convert between
numeric types? Alternatively, I'm experimenting with a hard coded schema
for the avrowriter output from the executesqlrecord processor. Is that the
best option?
Thanks

Reply via email to