ksqldb中的翻滚窗口是否不支持保留期？
在ksqldb中，翻滚窗口是一种用于处理流式数据的窗口类型。翻滚窗口是一种固定大小的窗口，它会随着时间的推移不断滚动，保持窗口内数据的固定数量。每当新的数据进入窗口时，最旧的数据将被丢弃。
关于保留期的支持，根据我所了解，ksqldb中的翻滚窗口是不支持保留期的。这意味着一旦数据进入窗口，它将一直保留在窗口内，直到被新的数据替换或窗口被关闭。
翻滚窗口的不支持保留期可能会导致一些数据管理方面的挑战。如果需要在窗口内保留数据的特定时间段，以便进行后续分析或处理，可能需要使用其他窗口类型或自定义逻辑来实现。
腾讯云提供了一系列与流式数据处理相关的产品和服务，例如腾讯云流计算 Oceanus、腾讯云消息队列 CMQ、腾讯云数据湖分析 DLA 等，这些产品可以帮助用户在云环境中进行高效的流式数据处理和分析。您可以通过访问腾讯云官方网站（https://cloud.tencent.com/）了解更多关于这些产品的详细信息和使用指南。
相关·内容
删除保留部分可以让它正常工作，因此它不能进行解析。 这是5.5版(在ksql命令行中键入的版本)，所以是最新的。
浏览 39提问于2020-06-19得票数 1
回答已采纳
我想做一个历史数据库，记录和检索卡夫卡主题的数据到一个永久的数据库。
我正在尝试使用KsqlDB来做这件事，我尝试使用来自ksql的表和流，但随着Kafka主题的消亡(保留期的延长)，它消失了。我的问题是“是否有可能使用ksqldb作为卡夫卡的历史学家？”谢谢。
浏览 4提问于2020-03-10得票数 0
1回答
我正在尝试理解和处理一些关于KSQL的例子。我在本地机器上安装了confluent社区版(6.0.0)。CURRENCY | VARCHAR(STRING) 在本主题中，我使用python producer来生成数据/ table.When我尝试使用下面的SQL在翻滚窗口上聚合> FROM TUMB> GROUP BY CURRENCY
> EMIT CHANGES; 我收到错误消息--“表聚合不支持<em
浏览 26提问于2020-12-12得票数 0
PayPal描述一个“荣誉期”，在你授权或重新授权付款后持续3天，直到第一次授权后29天。但是，文档并没有详细介绍这个荣誉期，只是您应该在其中捕获，并且可以通过重新授权重新启动过期的荣誉期。我有三个主要问题：
，荣誉期是什么时候开始/结束的？这是一个确切的72小时的窗口，从第二个，从你的时间？它是在午夜翻滚还是其他什么的？如果是，什么时区？--确定授权的
浏览 2提问于2021-07-22得票数 0
回答已采纳
下面是使用Kafka流的简单会话窗口： .groupBy() .withLoggingEnabled() .withValueSerde(valueSerde)
请注意，保留期必须至少足够长，以包含窗口数据的整个生命周期，从窗口
浏览 4提问于2019-10-17得票数 0
回答已采纳
2回答
我发现滑动窗口功能很有趣，并尝试让它工作。
但是，即使我将间隔设置为5秒，窗口后面的计算也会更频繁地完成。似乎每一条新消息都会执行元组窗口的execute-method。我希望计算等待5秒间隔内的所有消息。
浏览 0提问于2016-05-27得票数 1
3回答
假设相同的消息键有不同的值。user123@xyz.com }
userid: 1,userid: 1,在上面的例子中，我只需要用户更新的最新值，即“user789@XYZ.com”。我的kafka流应该只给我第三个值，而不是前两个值。
浏览 1提问于2020-04-01得票数 3
下面的代码“有效”，但我对Stores.persistentWindowStore()中传递的值的含义感到困惑。我找到了文档()，但是对于args的定义还不清楚。windowBy()值是否应该始终与persistentWindowStore()中的windowSize匹配？分段的数量是多少？
保留副本是为了什么？
浏览 0提问于2018-11-13得票数 1
回答已采纳
2回答
流式处理:翻滚窗口与微批处理
、、、、
流处理中5秒的翻滚窗口与微批处理时5秒的微批有何不同？两者都有5秒的非重叠窗口，在此期间它们处理记录，然后继续进行。
我知道在流处理中有时间的概念:事件、摄取和处理时间。我们是否可以推断，使用微批处理的流处理只是使用具有摄取时间或处理时间的翻滚窗口的流处理？
浏览 2提问于2019-05-01得票数 4
是否有可能在Kafka中创建一个日志压缩主题，其中通过压缩保留最旧的值(而不是新值)，用于分析目的？我有一个查询要创建，比如我正在寻找使用ksql / ksqldb /kstream的方法。我想到的最简单、最有效的方法是创建一个日志压缩的主题或ktable，它保留每个键的最早的</em
浏览 10提问于2020-05-11得票数 0
我有一个卡夫卡流应用程序，目前只是加入两个KStreams与一个5分钟的窗口，并将加入结果的另一个topic。我原以为磁盘空间<
浏览 2提问于2019-08-27得票数 1
回答已采纳
我有一些翻滚窗口触发器，设置为运行在特定的间隔6小时。它们需要在指定的时间运行(比如凌晨5点和11点，等等)--我已经设置了它们，以便它们是独立的，并且依赖于连接检查触发器。翻转窗口触发器仅在UTC中工作，当时钟在我们的时区发生变化时，触发时间会改变一个小时(向前或返回取决于一年中的时间)。这会导致数据晚到目的地，我被迫在夏令时左右手动部署新的触发器。我想知道是否有更好的<
浏览 4提问于2022-05-23得票数 0
在Azure Data Factory ( ADF )中，可以在一个ADF数据库表中设置数据库触发器吗？因此，如果有任何数据插入到一个ADF数据库表中，我可以触发SQL来转换数据，并将其插入到另一个不同格式ADF数据库表中。 请给我建议。谢谢。 谢谢, 哈特吉
浏览 25提问于2021-04-13得票数 0
回答已采纳
我目前正在使用kafka streams来整理窗口中的相关事件。如果所有相关事件没有在一个窗口内到达，在Kafka streams中是否有一种方法可以让我们获得过期事件的句柄。感谢您的回复。示例1：不活动状态持续时间为5 mins.Result:的</e
浏览 1提问于2017-03-31得票数 3
代码已经在生产环境中运行了几个月，但状态存储和changelog主题正在增长，并且存在空间使用问题。我希望记录在国家存储中在90天后过期。我读过一些关于在状态存储上应用基于时间的保留的方法，看起来窗口化聚合是实现这一点的一种方法。
我知道窗口聚合只适用于翻滚和跳跃窗口。滑动窗口仅适用于join操作。翻滚窗口在这种情况下不会起作用，因为我会有0-90，90-180<
浏览 15提问于2020-02-11得票数 1
1回答
我已经创建了一个重复性为1小时的翻滚窗口触发器，并将其附加到管道上。每当管道运行时，我想要处理前2小时，之后我想要处理当前小时。对于Ex:如果管道要在给定运行中处理10 AM到11 AM之间的记录，我希望同时处理8 AM到10 AM记录，在此之后，我希望处理当前窗口10 AM到11 AM。但是当管道被触发时，它会从之前的运行中寻找之前的依赖窗口(上午8点到上午10点)，并且只处理上午10点到11点的
浏览 22提问于2021-07-08得票数 0
目前在阅读flink的文档时，我发现flink中有很多支持，比如翻滚窗口、滑动窗口、会话窗口和自定义窗口的实现谢谢你的点子和建议~
浏览 0提问于2018-11-05得票数 0
1回答
如何将ADF中的翻滚窗口触发器参数化为每天在特定时间(9am-10am)之间运行。是否可以通过MyWindowStart和MyWindowEnd参数来实现？
你好，桑迪普
浏览 4提问于2020-05-07得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
