[GitHub] carbondata pull request #2695: [CARBONDATA-2919] Support ingest from Kafka i...

[jackylk]

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

    https://github.com/apache/carbondata/pull/2695#discussion_r216310510
  
    --- Diff: 
core/src/main/java/org/apache/carbondata/core/metadata/schema/table/CarbonTable.java
 ---
    @@ -1182,6 +1182,15 @@ private static void setLocalDictInfo(CarbonTable 
table, TableInfo tableInfo) {
         }
       }
     
    +  /**
    +   * Return the format value defined in table properties
    +   * @return String as per table properties, null if not defined
    +   */
    +  public String getFormat() {
    +    return getTableInfo().getFactTable().getTableProperties()
    +            .get("format");
    --- End diff --
    
    fixed


---