Hi guys
I am trying the DDL feature in branch 1.9-releasae.  I am stucked in creating a 
table from kafka with nested json format. Is it possibe to specify a "Row" type 
of columns to derive the nested json schema?

String sql = "create table kafka_stream(\n" +
                "  a varchar, \n" +
                "  b varchar,\n" +
                "  c int,\n" +
                "  inner_json row\n" +
                ") with (\n" +
                "  'connector.type' ='kafka',\n" +
                "  'connector.version' = '0.11',\n" +
                "  'update-mode' = 'append', \n" +
                "  'connector.topic' = 'test',\n" +
                "  'connector.properties.0.key' = 'bootstrap.servers',\n" +
                "  'connector.properties.0.value' = 'localhost:9092',\n" +
                "  'format.type' = 'json', \n" +
                "  'format.derive-schema' = 'true'\n" +
                ")\n";

 Thank you very much!

Reply via email to