[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[jira] [Created] (FLINK-9813) Build xTableSource from Avro schemas

François Lacombe created FLINK-9813:

             Summary: Build xTableSource from Avro schemas
                 Key: FLINK-9813
                 URL: https://issues.apache.org/jira/browse/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 :[https://avro.apache.org/docs/1.8.1/spec.html#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 avro.json

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