You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by twalthr <gi...@git.apache.org> on 2018/01/25 17:33:58 UTC

[GitHub] flink issue #5240: [FLINK-8240] [table] Create unified interfaces to configu...

Github user twalthr commented on the issue:

    https://github.com/apache/flink/pull/5240
  
    Thanks for the feedback @fhueske. I hope I could address most of it. I think we should merge this PR (if you agree) and add more PRs for this issue as the next steps. I suggest the following subtasks:
    
    - Add validation for the CSV format
    - Add full CsvTableSourceFactory support (incl. proctime, rowtime, and schema mapping)
    - Add a JSON schema parser to the JSON and logic for creating a table source from it
    - Add validation for the JSON format
    - Add validation for the Rowtime descriptor
    - Add validation for StreamTableDescriptor
    - Add validation for BatchTableDescriptor
    - Add KafkaTableSource factories 
    
    What do you think?


---