回答情况：
提问时间：
问题标签：
我想发出一个时间窗口的最后一条记录。这可以在常规的Flink中使用maxBy轻松完成，但我无法通过SQL API使其工作。我想要的是： GROUP BY key, TUMBLE(ts, INTERVAL '1' DAY)ds.keyBy(key) .maxBy(x -> x.getTs())
浏览 21提问于2020-05-26得票数 0
我想使用FlinkSQL选择处理窗口的最后一个元素。我尝试在Blink planner中使用ROW_NUMBER来实现这一点。
浏览 0提问于2020-05-30得票数 0
如果我想按天聚合数据分组，sql： selectcount(*) as numgroup by DATE_FORMAT(ctime, 'yyyyMMdd'); 如何按周分组汇总数据？
浏览 55提问于2020-09-25得票数 0
回答已采纳
sql：CREATE TABLE tab1 ( data Row<id BIGINT,name VARCHAR>) WITH ...;我该怎么做呢？
浏览 0修改于2020-06-10得票数 1
I成功地将csv文件数据从s3加载到FlinkSql本地机器中。path'='s3://d11-data-lake-load/flink/events_data/test_flink/test-csv',);
与我尝试从S3加载到FlinkSql
浏览 7修改于2021-05-12得票数 0
我在Flink SQL (1.13)中使用会话窗口。是否有方法(必须在SQL中，没有UDF等)获取某个字段的最后一个值(换句话说:这将是window_end的值)？我正在尝试： SELECT user_account_id, SESSION_END(request_timestamp, INTERVAL '30' MINUTE) AS window_end,
LAST_VA
浏览 289提问于2021-08-25得票数 0
回答已采纳
我想定义函数MAX_BY，它接受类型T的值和类型Number的排序参数，并根据排序从窗口返回最大元素(类型为T)。我试过了 public T getValue(Tuple2<T, Number> tuple) { }
public Tuple2<T, Number&g
浏览 8提问于2020-05-27得票数 2
CREATE TABLE user_log ( b STRING 'connector.type' = 'kafka', 'connector.topic' = 'test', 'connecto
浏览 2提问于2020-06-11得票数 1
我们可以用两种不同的方式使用窗口。 FROM table和 FROM table我想知道这两种机制是否能够表达相同的东西，或者这两种机制的主要区别和可能的用例是什么？
浏览 2提问于2020-05-27得票数 1
回答已采纳
现在flinksql只支持postgres存储元数据，如果我想获得oracle元数据，如何重写postgresCatalog？
浏览 1提问于2021-12-16得票数 0
我使用FlinkKafkaConsumer从Kafka读取数据，然后将数据转换为表，最后用FlinkSQL将接收器数据返回到kafka(kafka-连接器表)。我的问题是在哪里可以使用FlinkSQL添加这个属性。
浏览 10提问于2022-07-01得票数 0
回答已采纳
启用检查点的flinksql客户端配置文件的示例是什么？ 当我通过flink sql客户端提交流作业时，检查点未启用。
浏览 205修改于2021-01-15得票数 0
我们正在尝试运行一个FlinkSQL查询，该查询应用了一些重复，然后窗口并聚合了该去复制的结果，但是在查询计划时遇到了以下错误：org.apache.flink.table.api.TableException
浏览 56修改于2022-08-23得票数 0
我有一个运行FlinkSQL的Flink作业，其设置如下：
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment
浏览 3修改于2021-10-27得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号