see example : create table conv ( SM ROW(objectType STRING, verb string, actor ROW(orgId string), object ROW(contentCategory string, links ARRAY<ROW(ecmType STRING)>)), timestamp string
timestamp
) WITH ( 'connector' = 'kafka', -- using kafka connector 'topic' = 'sj1_spark_conv_hdfs', )
how to use explode on SM.object.ecmType instead of using ecmType[1]
2.1m questions
2.1m answers
60 comments
57.0k users