[GitHub] flink pull request #4894: [FLINK-7548] [table] Improve rowtime support of Ta...

[fhueske]

Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4894#discussion_r147358782
  
    --- Diff: 
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
 ---
    @@ -84,6 +86,13 @@
                return typeInfo;
        }
     
    +   @Override
    +   public TableSchema getTableSchema() {
    +           return new TableSchema(
    +                   ((RowTypeInfo) typeInfo).getFieldNames(),
    --- End diff --
    
    What do you think about adding a `fromTypeInfo` method to the companion 
object that creates a `TableSchema`?


---