[FLINK-37729][flink-formats] ResultTypeQueryable for Avro serialization schema #26507
Conversation
…ion schema Signed-off-by: Pawel Leszczynski <[email protected]>
| * @return TypeInformation of the produced type | ||
| */ | ||
| @Override | ||
| public TypeInformation getProducedType() { |
There was a problem hiding this comment.
This should be TypeInformation<T>. You probably need to cast the returns though but I think it makes things more explicit.
There was a problem hiding this comment.
The common type for both cases is ResultTypeQueryable<GenericContainer> as both SpecificRecord and GenericRecord extend GenericContainer. However, I could not make it work for GenericRecordAvroTypeInfo to be casted into TypeInformation<GenericContainer>
| if (schema == null) { | ||
| throw new IllegalStateException( | ||
| "The produced type is not available before the schema is initialized."); | ||
| } else { | ||
| return new GenericRecordAvroTypeInfo(schema); | ||
| } | ||
| } |
There was a problem hiding this comment.
Shouldn't the produced type be of row? Naively I'd expect to have the same type bound to
SerializationSchema<RowData>, ResultTypeQueryable<GenericRecord>
There was a problem hiding this comment.
Do you know any convenient helper to convert RowData into sth extending TypeInformation?
Implement
ResultTypeQueryableinterface forAvroSerializationSchemaandAvroRowDataSerializationSchemato make it exposed via existing lineage interfaces.Does this pull request potentially affect one of the following parts:
@Public(Evolving): noDocumentation