Blink 1.11 create view是不是没有办法把rowtime带下去？

[周虓岗]

通过table api的// declare an additional logical field as an event time attribute

Table table = tEnv.fromDataStream(stream, $("user_name"), $("data"), $("user_action_time").rowtime()");




可以把eventtime往后传，

如果使用createview的话怎么把这个time attribute往后带吗？




不往后传的话可能会

这个有什么方法吗？

 

[hailongwang]

Hi zhou,
   你是指的 createTemporaryView 这个方法吗，这个方法上也可以指定字段，例子可以查看[1]。
其中 createTemporaryView 的实现也是间接调用了 fromDataStream 方法[2]。


[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html#create-a-view-from-a-datastream-or-dataset
[2] https://github.com/apache/flink/blob/c24185d1c2853d5c56eed6c40e5960d2398474ca/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java#L253


Best,
Hailong




在 2020-11-16 13:48:35，"周虓岗" <[hidden email]> 写道：

通过table api的// declare an additional logical field as an event time attribute

Tabletable=tEnv.fromDataStream(stream,$("user_name"),$("data"),$("user_action_time").rowtime()");


可以把eventtime往后传，
如果使用createview的话怎么把这个time attribute往后带吗？


不往后传的话可能会


这个有什么方法吗？






 

[周虓岗]

不是，我值得是table api可以带event time。 如果整个使用sql表达，怎么把time attribute待下去










在 2020-11-16 15:53:44，"hailongwang" <[hidden email]> 写道：

>Hi zhou,
>   你是指的 createTemporaryView 这个方法吗，这个方法上也可以指定字段，例子可以查看[1]。
>其中 createTemporaryView 的实现也是间接调用了 fromDataStream 方法[2]。
>
>
>[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html#create-a-view-from-a-datastream-or-dataset
>[2] https://github.com/apache/flink/blob/c24185d1c2853d5c56eed6c40e5960d2398474ca/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java#L253
>
>
>Best,
>Hailong
>
>
>
>
>在 2020-11-16 13:48:35，"周虓岗" <[hidden email]> 写道：
>
>通过table api的// declare an additional logical field as an event time attribute
>
>Tabletable=tEnv.fromDataStream(stream,$("user_name"),$("data"),$("user_action_time").rowtime()");
>
>
>可以把eventtime往后传，
>如果使用createview的话怎么把这个time attribute往后带吗？
>
>
>不往后传的话可能会
>
>
>这个有什么方法吗？
>
>
>
>
>
>
>

[hailongwang]

select 时候带上这个字段？ 只要这个字段没有参与计算，就不会被物化。
如果是 window 处理后，还需要具有时间属性的字段，可以参考[1]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/queries.html#group-windows


在 2020-11-16 14:57:39，"周虓岗" <[hidden email]> 写道：

>
>
>
>
>
>
>
>
>
>不是，我值得是table api可以带event time。 如果整个使用sql表达，怎么把time attribute待下去
>
>
>
>
>
>
>
>
>
>
>在 2020-11-16 15:53:44，"hailongwang" <[hidden email]> 写道：
>>Hi zhou,
>>   你是指的 createTemporaryView 这个方法吗，这个方法上也可以指定字段，例子可以查看[1]。
>>其中 createTemporaryView 的实现也是间接调用了 fromDataStream 方法[2]。
>>
>>
>>[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html#create-a-view-from-a-datastream-or-dataset
>>[2] https://github.com/apache/flink/blob/c24185d1c2853d5c56eed6c40e5960d2398474ca/flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java#L253
>>
>>
>>Best,
>>Hailong
>>
>>
>>
>>
>>在 2020-11-16 13:48:35，"周虓岗" <[hidden email]> 写道：
>>
>>通过table api的// declare an additional logical field as an event time attribute
>>
>>Tabletable=tEnv.fromDataStream(stream,$("user_name"),$("data"),$("user_action_time").rowtime()");
>>
>>
>>可以把eventtime往后传，
>>如果使用createview的话怎么把这个time attribute往后带吗？
>>
>>
>>不往后传的话可能会
>>
>>
>>这个有什么方法吗？
>>
>>
>>
>>
>>
>>
>>