Benchao is right.
嵌套字段是无法直接访问的,需要逐级引用到。
On Thu, 12 Mar 2020 at 00:45, Benchao Li wrote:
> Hi 周炎,
>
> 你的`date` 和 `time`都是在嵌套结构内部的字段,需要用*request.`value`.`date`*和*
> request.`value`.`time`*来使用它们。
>
> 周炎 于2020年3月11日周三 下午5:42写道:
>
> > DDL语句如下:
> > CREATE TABLE ods_usage_naga_dsp_filter (
> > re
Hi 周炎,
你的`date` 和 `time`都是在嵌套结构内部的字段,需要用*request.`value`.`date`*和*
request.`value`.`time`*来使用它们。
周炎 于2020年3月11日周三 下午5:42写道:
> DDL语句如下:
> CREATE TABLE ods_usage_naga_dsp_filter (
> request row<`value` row varchar,reqid varchar,source varchar,`time` varchar,`filter`
> array> >>>,
> event_
DDL语句如下:
CREATE TABLE ods_usage_naga_dsp_filter (
request row<`value` row> >>>,
event_ts as to_timestamp(concat(`date`,`time`),'-MM-ddHH:mm:ss'),
WATERMARK FOR event_ts AS event_ts - interval '60' second
)WITH (
'connector.type' = 'kafka',
'format.fail-on-missing-field'='false',
'co