François Lacombe created FLINK-9813:

             Summary: Build xTableSource from Avro schemas
                 Key: FLINK-9813
             Project: Flink
          Issue Type: Wish
          Components: Table API & SQL
    Affects Versions: 1.5.0
            Reporter: François Lacombe

As Avro provide efficient data schemas formalism, it may be great to be able to 
build Flink Tables Sources with such files.

More info about Avro schemas 

For instance, with CsvTableSource :

Parser schemaParser = new Schema.Parser();

Schema tableSchema = schemaParser.parse("avro.json");

Builder bld = CsvTableSource.builder().schema(tableSchema);


This would give me a fully available CsvTableSource with columns defined in 

It may be possible to do so for every TableSources since avro format is really 
common and versatile.

This message was sent by Atlassian JIRA

Reply via email to