Re: 关于Table API 或 SQL 如何设置水印的疑问?

2023-05-30 文章 yidan zhao
你在hive的catalog中定义表的时候就可以定义好event time,以及watermark呀。 ZhaoShuKang 于2023年5月25日周四 08:53写道: > > 各位老师好,我最近在做Flink查询Hive的功能,需要用到窗口处理数据,在编写代码过程中无法设置水印,我看官网看到Table API & SQL > 设置事件时间有三种方式: > 1、在 DDL 中定义 > 2、在 DataStream 到 Table 转换时定义 > 3、使用 TableSource 定义 >

关于Table API 或 SQL 如何设置水印的疑问?

2023-05-24 文章 ZhaoShuKang
各位老师好,我最近在做Flink查询Hive的功能,需要用到窗口处理数据,在编写代码过程中无法设置水印,我看官网看到Table API & SQL 设置事件时间有三种方式: 1、在 DDL 中定义 2、在 DataStream 到 Table 转换时定义 3、使用 TableSource 定义 而我使用的是HiveCatalog查询hive,貌似用不上以上三种方式。所以我想问问各位老师,有没有一种办法可以直接在Table上设置某个字段为事件事件,并且设置水印? 另外说明,我的第一版代码是将Table转换为DataSteam,然后再设置水印和窗口,但是执行转换过程非常耗时,并且在源码中