pvary commented on issue #10710:
URL: https://github.com/apache/iceberg/issues/10710#issuecomment-2432586094
In Flink, it is possible to create a new type, like:
```
class WriteResultType extends TypeInformation<WriteResult>
```
This can implement the `createSerializer` method, ike:
```
public TypeSerializer<WriteResult> createSerializer(SerializerConfig
serializerConfig) {
```
And this type can be used like `returns(new WriteResultType())`.
This way the user can specify the type/serializer which is used for the
stream. This is far from easy, it is doable.
Also this serializer would be a nice addition, so we could
control/understand what is travelling on the wire, and avoid or highlight
potential situations when the serialised data changes.
Also we should respect the Iceberg community's decision about the layout of
the core API.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
