Re: Get types from Row

I'm not sure if this helps with your need to vary the Sink's schema at runtime, but FWIW you can get the 'schema' of the input datastream via DataStream.getType

Re: Get types from Row

Hi Jose, I have facing a similar issue when working on schema evolution in the Iceberg connector. The RowData is optimized in a way, that it is expected to have the same schema for the lifetime of the deployment. This avoids any extra serialization for every record. To work around this I see 2 opt

Get types from Row

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 Then I need to process that element, depending what the Type is