腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
flink
流
统计
不同
的
日
活跃
用户
apache-flink
、
flink-streaming
我正在
使用
Flink
streaming来替换我
的
ETL
流
。我工作
的
其中一个任务是-计算
不同
的
每日
活跃
用户
。这项任务本身并不太难实现。问题是,我需要每小时更新仪表板上的当前计数。如果我创建一个一小时
的
窗口,我将只获得一个小时
的
不同
计数,但如果
用户
在
不同
的
小时返回,我将计算他两次。 有谁有主意吗? 谢谢!
浏览 44
提问于2019-09-22
得票数 0
1
回答
在雅典娜或Quicksight上滚动计数
sql
、
datetime
、
count
、
presto
、
amazon-athena
我有这个数据集 1/ 30 /2020上
的
100意味着在过去
的
30天内,有100个
不同
的
活跃
用户
(从1/1/2020到1/30/2020)。2020年1月31
日
的
102意味着在过去30天内有102个
不同
的
浏览 17
提问于2020-11-10
得票数 0
1
回答
幻灯片尺寸小、内容相同
的
Flink
窗口优化?
redis
、
apache-flink
我们已经开发了一个
Flink
应用程序,它接收具有字段
的
消息,例如
Flink
应用程序中
的
id, value1, value2, ...,它们由id键控,并分配
不同
大小
的
滑动窗口和10秒
的
slide。我们
使用
AggregateFunction为每个id计算一些
统计
信息,结果数据
流
被汇聚到Redis。setParallelism(20); statistics.addSink(new CustomRedisSink())
浏览 12
提问于2021-01-12
得票数 1
回答已采纳
1
回答
Facebook Analytics
用户
活动计数错误
ios
、
facebook-analytics
我们
使用
Facebook Analytics来计算每日
活跃
用户
。然而,iOS
的
数量与服务器
统计
的
数量有很大
的
不同
。Facebook
的
数据数量比我们少得多。我们通过api访问日志来
统计
活跃
用户
。我想知道Facebook Analytics是
如何
计算数据
的
?
浏览 12
提问于2018-06-06
得票数 0
1
回答
Apache
flink
从late window访问键控状态
apache-flink
、
flink-streaming
我正在编写一个
Flink
应用程序,它
使用
kafka主题中
的
时间序列数据。时间序列数据包含指标名称、标记键值对、时间戳和值等组件。我已经创建了一个滚动窗口,用于根据指标键(指标名称、键值对和时间戳
的
组合)聚合数据。我正在考虑
使用
flink
的
"allowedLateness“功能将延迟指标发送到
不同
的
流
。,“收集延迟指标并找到延迟指标的百分比”操作员能否访问主流更新
的
"MapStat
浏览 17
提问于2021-08-09
得票数 0
回答已采纳
1
回答
如何
使用
kafka窗口汇总过去12个月
的
用户
数量?
java
、
apache-kafka-streams
嗨,我是最近开始工作的卡夫卡
流
java api。请您在下面的用例中了解一下我们
如何
在kafka
流
中解决问题。 我们正在寻找
不同
的
用户
,
统计
谁在过去12个月注册。例如,如果当前月份是2022年8月,那么我需要2021年8月1
日
至2022年7月31
日
之间
的
用户
数量。我正在尝试与滚动窗口365天
的
持续时间,但它不适合要求。为什么我们可以在kafka
流
中定义区间聚合。ue
浏览 4
提问于2022-08-10
得票数 -1
2
回答
flink
-sql
如何
处理像“count(Distinct)”这样
的
场景?
hadoop
、
apache-flink
我需要
使用
flink
-sql实时计算“每日
活跃
用户
”,这就像是对每日数据
的
“count(distinct )”操作。 我
的
问题是,如果userA像预期
的
那样在凌晨1点登录,并且
flink
将DAU加1。现在,userA在晚上10点再次登录,
flink
-sql怎么知道今天早上userA已经被处理了?是否需要对全天
的
登录日志重复做count(distinct )?如果不是,
flink
如何
浏览 6
提问于2020-09-14
得票数 0
2
回答
是否可以在没有Azure订阅
的
情况下获取基本
的
应用程序
使用
统计
数据?
windows-store-apps
、
win-universal-app
、
uwp
、
windows-store
、
windows-dev-center
有没有办法在没有Azure帐户
的
情况下启用应用程序
使用
统计
数据,就像我们在崩溃报告中获得
的
一样?
浏览 6
提问于2016-05-29
得票数 0
1
回答
流在Hadoop中
的
应用
hadoop
、
spark-streaming
、
apache-flink
、
flink-streaming
、
flink-cep
我正在尝试学习
的
例子。在这个例子中,我确实看到他们创建了一个单独
的
应用程序(类似于
流
应用程序),该应用程序生成和消费数据,并在数据上应用模式匹配。他们现在还没有在.Till(如卡夫卡)之间放置一个
流
层,单应用程序就足以满足这一目的,这使得它非常优化。现在,我知道,如果我
使用
Kafka,那么我需要两个应用程序;一个用于将数据摄取到Kafka主题中,另一个用于消费Kafka主题
的
数据。我有几个问题我没有得到回答: 为什么在这个例子中他们没有
使用
任何
流
层
浏览 2
提问于2016-06-13
得票数 0
0
回答
大家,请教一下微信小游戏
如何
自己做埋点
统计
?
访问管理
、
微信
、
小程序
我们想自己对自己多个微信小游戏做
统计
,需求如下:2、
统计
小程序新增流量中,来源于哪些渠道。1、微信小游戏
如何
来定义
用户
的
唯一性? 是通过微信
的
openid吗? 感谢您
浏览 278
提问于2020-06-05
1
回答
洞察--什么是“
活跃
用户
”?
facebook
、
analytics
、
facebook-insights
我有一个应用程序,其中
的
数字如下:Monthly Active Users: 2,994Users that commented on a stream story from your application 我
的
应用程序
的</e
浏览 2
提问于2012-01-19
得票数 2
4
回答
如何
跟踪插件
的
活跃
用户
?为什么WordPress.Org不提供这个呢?
plugin-development
、
statistics
从安卓到iOS,似乎每个主要
的
应用平台对开发者都有很好
的
统计
数据。但是,如果您通过WordPress.org发布插件,则不允许包含任何第三方跟踪代码(理由充分)。那么,我怎样才能按
日
/周/月跟踪活动
用户
呢?
如何
在白天获得图表后面的原始数据以供下载?我也有插件
使用
插件更新检查器通过Janis /w-影子,因为它们不是托管在WordPress.org上.那么,其他插件开发人员
如何
跟踪下载和
活跃</em
浏览 0
提问于2012-10-16
得票数 5
1
回答
如何
在
Flink
表API中加入两个数据
流
和滑动窗口函数?
apache-flink
、
flink-streaming
、
apache-zeppelin
、
flink-sql
、
amazon-kinesis-analytics
我有两个来自两个Kafka主题
的
流
表,我想加入这些
流
并对所连接
的
数据执行聚合功能。需要
使用
滑动窗口连接
流
。TIMESTAMPDIFF(SECOND, ep.event_
flink
_time, cep.event_
flink
_time) as timediff, HOP_START (cep.event_
flink
_time, INTERVAL '5' MINUTES, INTERVAL '10
浏览 25
提问于2022-05-24
得票数 0
1
回答
Flink
中
的
低延迟
流
与多个元数据
流
的
结合(丰富)
apache-flink
、
flink-streaming
我正在为
流
分析方案评估
Flink
,并且还没有找到关于
如何
实现我们今天在遗留系统中所做
的
一种ETL设置
的
足够信息。一个非常常见
的
场景是,我们
使用
了关键
的
、慢吞吐量
的
元数据
流
,我们希望
使用
这些数据流在高吞吐量数据流上进行丰富,如下所示:这就引出了两个关于
Flink
的
问题:
如何
通过缓慢更新时间窗口重叠但不相等
的
流来丰富快速
浏览 3
提问于2017-11-21
得票数 1
回答已采纳
1
回答
Apache是删除了StreamOperatorTestHarness类,还是转移到了
不同
的
工件上?
maven
、
apache-flink
、
flink-streaming
我
使用
intellij、maven 3和
flink
1.15.1编写有状态
流
作业。我正在尝试为我
的
自定义KeyedProcessFunction编写单元测试,并尝试遵循文档以及添加提到
的
的
依赖项。我对
使用
KeyedOneInputStreamOperatorTestHarness类很感兴趣,但是在我
的
任何依赖项中都找不到这个类(下面发布
的
修改后
的
pom )。
Flink
>= 1.15.0现在不
浏览 8
提问于2022-08-01
得票数 1
回答已采纳
1
回答
Flink
如何
发现每个键
的
所有kafka分区
apache-flink
、
flink-streaming
我在我
的
数据
流
中
使用
"keyby“。我希望
flink
发现每个密钥
的
所有kafka分区。我有30个分区和12个任务。我通过
用户
id "keyby“我
的
数据。我认为每个任务
的
flink
只能发现特定
的
kafka分区&我不能在一个任务中检测到每个
用户
的
所有数据。
浏览 29
提问于2019-10-07
得票数 0
1
回答
Apache启用连接排序
apache-flink
、
sql-execution-plan
、
flink-sql
我注意到Apache没有优化表
的
连接顺序。目前,它保持
用户
指定
的
连接顺序(基本上,它从字面上接受查询)。我认为Apache方解石可以优化联接
的
顺序,但出于某种原因,这些规则在Apache中没有
使用
。x4")如果我们想要计算tableOne和tableTwo中
的
行数,则这两种情况下<
浏览 0
提问于2018-12-03
得票数 3
回答已采纳
1
回答
在
flink
广播
流
中处理大数据
java
、
apache-kafka
、
apache-flink
、
flink-streaming
、
broadcast
我
使用
的
是一个
Flink
流
应用程序,它
的
输入源是Kafka。在我
的
应用程序中总共
使用
了4个
流
。一个是主要数据
流
,另一个是3个用于广播
流
。
流
B是一个丰富数据集。
流
B是C
流
、D
流
、E
流
的
组合流。它是一个很大
的
流
(所有3个
浏览 3
提问于2020-07-24
得票数 0
1
回答
提取Firebase / BigQuery DAU、WAUs和MAU
firebase
、
google-analytics
、
google-bigquery
、
firebase-analytics
-7天
活跃
用户
:1月24
日
至1月30
日
(在您
的
日期范围
的
最后7天)在您
的
站点或应用程序上启动会话
的
唯一
用户
的
数量。- 14天
活跃
用户
:1月17
日
至1月30
日
(日期范围
的
最后14天)在您
的
站点或应用程序上启动会话
的
独特
用户
的
数量。- 30天
活跃</em
浏览 3
提问于2017-01-11
得票数 4
回答已采纳
1
回答
用动态限制
Flink
中
的
网络流量
apache-flink
、
flink-streaming
、
amazon-kinesis
、
amazon-kinesis-analytics
我在Amazon
的
服务(托管
Flink
集群)中运行了一个
Flink
应用程序。在这个应用程序中,我从一个名为keyBy userId
的
动态
流
中读取
用户
数据,然后聚合一些
用户
信息。考虑到这一点,我正试图决定
如何
使用
什么作为我
的
Flink
应用程序读取
的
Kinesis
流
的
分区键。我
的
目标是限制
Flink
集群中主机之间<
浏览 4
提问于2020-02-18
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(三):生产环境中的Flink
Flink概念:编程模型下
Apache Flink的下一步:不止于流处理
Flink 的事件时间(Event Time)和处理时间(Processing Time)是什么?
加米谷大数据:比拼生态和未来,Spark和Flink哪家强?
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券