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!