回答情况：
提问时间：
问题标签：
我需要使用flink-sql实时计算“每日活跃用户”，这就像是对每日数据的“count(distinct )”操作。
我的问题是，如果userA像预期的那样在凌晨1点登录，并且flink将DAU加1。现在，userA在晚上10点再次登录，flink-sql怎么知道今天早上userA已经被处理了？是否需要对全天的登录日志重复做count(distinct )？
浏览 6修改于2020-09-14得票数 0
我正在尝试检查给定的字符串是否出现在字符串数组中换句话说，我正在寻找与prestoSQL的contains()数组函数()等价的flink SQL。
浏览 9提问于2021-03-25得票数 0
我正在搜索函数from_unixtime(bigint unixtime)的等效值，该函数存在于Spark和Flink-SQL中。
浏览 0修改于2018-09-09得票数 2
根据
后续:由于Maven central没有提供它们，所以如果我不想使用用户定义的依赖项，我想知道如
浏览 4提问于2021-04-02得票数 0
回答已采纳
metricsLabels: endpoint="tcp" instance="172.19.88.111:9091" job="pushgateway" namespace="flink-sql="model1122"} 8
flink_jobmanager_numRegisteredTaskManagers{host="flink_jobmanager",instance="",job="flink
浏览 8提问于2021-05-24得票数 0
我正在使用Ververica平台来玩Flink-SQL。因此，我使用SQL编辑器来开发我的查询。在执行查询以预览我在Flink UI中看到的结果时，作业的并行性为1。
浏览 4修改于2022-02-09得票数 0
我使用的是Flink-SQL 1.13。目标是实时计算新用户的数量。
由于一些限制，我不能直接使用注册事件，因为在那里创建的帐户就像平台传递一样。也许我可以把历史用户放到redis hyperloglog中，但似乎Flink-SQL没有一个redis连接器yet...Thanks来帮助你提前……
浏览 83提问于2021-05-24得票数 0
"GROUP BY TUMBLE(rowtime(), INTERVAL '1' DAY), user");
请给我一个关于rowtime.Thx的flink-sql
浏览 4提问于2017-06-08得票数 0
回答已采纳
0回答
org.apache.hadoop.fs.cosnative.NativeCosFileSystem
flink 1.10 版本读取hive 2.3.7 的数据 将hive下的以来全部copy 到 flink的依赖下，同时放入了 hadoop-cosde 2个jar包,启动flink-sql
浏览 571提问于2022-05-19
我添加了在上可用的flink-sql连接器。有人能帮我举个合适的例子来做这个吗？
浏览 23修改于2022-02-04得票数 0
2回答
我正在尝试将Flink 1.14.4与HBase版本2.2.14连接；我添加了Hbase连接器jar flink-SQL连接器-HBASE-2.2-1.15.2.jar，但是对于2.2.x版本，这是jar
浏览 73修改于2022-10-24得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号