[
https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16552726#comment-16552726
]
François Lacombe edited comment on FLINK-9813 at 7/25/18 9:25 AM:
------------------------------------------------------------------
Then it would be ok to use {{AvroSchemaConverter#convertToTypeInfo()}} and
built a Csv from typeInfo.
Currently, the docs don't explain how to define a CsvTableSource from Csv
descriptor
[https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sourceSinks.html#csvtablesource]
How can I manage to do so?
Is this only available in coming 1.6 release?
was (Author: flacombe):
Then it would be ok to use {{AvroSchemaConverter#convertToTypeInfo()}} and
built a Csv from typeInfo.
Is this only available in coming 1.6 release?
> 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
> Priority: Trivial
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> 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
(v7.6.3#76005)
