我使用的是Flink-SQL 1.13。目标是实时计算新用户的数量。user_id game_id login_t
浏览 83提问于2021-05-24得票数 0
我需要使用flink-sql实时计算“每日活跃用户”，这就像是对每日数据的“count(distinct )”操作。
我的问题是，如果userA像预期的那样在凌晨1点登录，并且flink将DAU加1。现在，userA在晚上10点再次登录，flink-sql怎么知道今天早上userA已经被处理了？是否需要对全天的登录日志重复做count(distinct )？如果不是，fli
浏览 6提问于2020-09-14得票数 0
摄入卡夫卡的数据，比如50个分区(输入速率- 100,000毫希/秒)
将输出存储在Cassandra上我正在寻找一个实时流媒体平台，并发现Flink是一个非常适合实时和批处理。我是否需要在google数据流中编写数据管道来执行flink上的步骤序列，还是有其他方法来执行实时<
浏览 2提问于2016-06-10得票数 3
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。
浏览 0提问于2018-06-21得票数 1
回答已采纳
我的项目目前构建在Azure上(数据存储在Azure SQL server中)，我目前正在尝试通过利用PyFilnk将流/批处理功能引入到我的项目中。但是，我没有找到任何关于如何将PyFlink连接到Azure SQL server的文档，有没有一种方法可以在PyFlink中使用Azure SQL server作为数据源？
浏览 13提问于2021-07-22得票数 0
2回答
我在一个应用程序上工作，我想在实时事件和过去的事件上运行Flink SQL。我尝试了一个POC，其中Flink在Kafka等流源上运行SQL，SQL查询只返回新的事件/更改。但是，我想在整个数据上运行SQL，一些数据可能会随着时间的推移而变化。基本上，我的要求是连续查询整个数据。如何使用Flink或任何其他流媒体解决方案来实现这一点？
浏览 0提问于2019-12-22得票数 2
1回答
我已经从服务器备份了sql数据库，并尝试在我的计算机上进行还原。恢复窗口消失，说成功恢复。在数据库列表中，无法访问我的数据库。看上去就是这样。在googling中，我从microsoft：服务提供商_变化_用户_登录(Transact-SQL)中找到了以下内容：GO
EXEC sp_change_users_login'Auto_Fix', 'user
浏览 0提问于2012-02-14得票数 3
回答已采纳
我用我的微软帐户登录到windows 8。计算机视我为BAGGINS\Max (machinename/user)，正如预期的那样。
我有一个应用程序，它首先使用实体框架代码来生成数据库。但是，当使用代码访问数据库时，我会看到一个错误，即"BAGGINS\Max“没有访问数据库的权限。我已经进入了sql server，BAGGINS\Max对sql服务器实例拥有完全的权限，但没有为sql serv
浏览 1提问于2013-06-28得票数 0
我有一些数据库问题。
我在本地计算机上安装了SQL Server Developer。当我打开SQL Server Management Studio并使用windows身份验证登录时，没有任何问题。我在那里创建了一个新数据库并添加了一个新用户。新用户是数据库的所有者。当我断开与windows会话的连接，并尝试在SQL Server身份验证模式下以新创建的用户登录时，我收到“can
浏览 0提问于2010-11-26得票数 3
回答已采纳
我试图在我的一个项目中使用Apache的表概念来实时组合来自多个来源的数据。不幸的是，我的团队成员都是Node.JS开发人员。因此，我正在寻找从NodeJS连接到Flink并从它进行查询的可能方法。在SQL的中，有人提到
基于此，是否有
浏览 15提问于2022-07-19得票数 1
我是flink的新手，想了解如何使用FLINK运行我的用例:应用程序有三个输入数据源a)历史数据b)从kafka获取所有实时事件c)获取将具有触发条件的控制事件 由于应用程序正在处理历史数据，因此我认为我将合并历史数据和实时数据要触发事件，我们必须在控制事件的帮助下编写SQL查询，该事件是输入源，并且包含where子句。我的问题是在数据位于Stream中时构建SQL</em
浏览 37提问于2020-07-01得票数 1
1回答
具体而言:在该网站的生存期内，已有872个用户：然而，如果我们只看销售下降后的数据，我们就会得到996个用户，尽管这只是之前数据的一个子集。这怎麽可能？其次，我对它的理解是，新用户在站点的生命周期内应该在站点的生命周期内使用==，对吗？📷
浏览 0提问于2015-01-12得票数 3
回答已采纳
3回答
我正在使用R，并有一个数据表，人们在玩某个网络游戏。2017-01-01, A133, 2018-01-01, B我希望找到2018年每个国家新用户的数量，定义为2018年登录的用户数量，而不是2017年登录的用户数量。例如，如果上述数据表是整个数据表，则国家A在2018年将有1个新用户(用户43
浏览 0提问于2018-07-17得票数 0
回答已采纳
为了执行一些活动查询，而不是在数据流之上定义(连续的或仅附加的)数据库视图。我知道我可以将我的表导出到一些数据库中，并使用SQL动态查询这个数据库，但这是一种尴尬的行为。Flink的美妙之处在于，一切都是实时的，所有的东西都是流，那么是否可以从外部程序实时查询Flink表呢？
浏览 5提问于2017-10-25得票数 2
回答已采纳
1回答
为了学习目的，我正在构建一个简单的数据管道。我有来自Kafka的实时数据，我想使用Flink进行一些转换。
使作业工件在/opt/flink
浏览 5提问于2022-01-08得票数 0
回答已采纳
我的计算机上本地安装了SQL Server 2014。Windows进行了更新，不知何故，我的用户帐户被损坏了。我在我的计算机上创建了一个具有管理员权限的新用户帐户，SQL Server自动将新用户帐户添加为sys管理员。当我用我以前的windows账号登录SSMS时，我发现了这一点。我还注意到，添加的新用户帐户带有SQL Server身份验证。我希望新帐户具有Windows身份验证，但不知何故它是灰色的。有人知道为什么吗？此外，当我
浏览 21提问于2019-03-16得票数 0
我目前正在使用Firebase电子邮件身份验证作为登录方法。但是，当我注册新用户时，新用户的电子邮件只会保存到“身份验证”面板，而不会保存到“实时数据库”中。现在我想为特定的用户添加更多的信息。当新用户注册时，新用户的电子邮件是否会保存到“身份验证”面板和实时数据库？
我不知道如何从身份验证中检索用户电子邮件。我知道可能有一种方法可以得到用户的电子邮件，即通过使用“用户UID"？
浏览 0提问于2019-01-20得票数 0
回答已采纳
我有一个数据流(来自csv文件)，它在每一行中包含字符串和一个特定值(双精度)。我在Flink中使用keyBy()按特定属性(国家)对这些值进行分组，因此对于每个不同的国家，我都有一组不同的元组(层)。我计算数据流中每个组(层)的均值和方差，并返回每个层的数量均值/方差(μ/σ)。在我的Flink程序中，当我的算法运行时，我需要将这个量的所有最后值(均值/方差)相加，即来自每一层的最新值。换句话说，如果从每一层得到一个数量
浏览 3提问于2020-02-19得票数 0
1回答
我想使用BigTable作为Flink作业的接收器：
我可以使用Datastream API吗？
浏览 2提问于2021-01-28得票数 1
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
