Hi, I want to build a custom Sink that receives a Row (or GenericRowData or RowData, depending on your reply) and needs to do some processing before sending it to the external sink.
So it should be something like this: Input -> ROW<Field1 Type1, Field2 Type2, ..., FieldN, TypeN> Then I need to process that element, depending what the Type is, I need to process it in a different way, so I need to fetch the Data Type of each field at runtime. The types can change from run to run, so the sink won't know them. Is there a way to get the types from the Row itself? I am OK using other Data types if needed. The only solution I found to this is passing an Schema and when iterating through the row and fetching the data type from the schema. Thanks!
