1回答
Flink keyBy:密钥太多？
apache-flink
首先，这是我的代码逻辑 source.keby(key).process(computeLogic)
.sink(sinkFunction) 我的问题是： 如果我有太多的关键点，假设超过10,000个关键点，每个关键点会有一个窗口吗？太多的Windows会占用太多的内存并导致OOM吗？
浏览 55提问于2020-12-15得票数 0
回答已采纳
1回答
如何使用ATOM“查找和替换”标记中的特定字符？
regex、replace、find、atom-editor
我只需要帮助替换我的-中的alt标记(而不是代码/html的其余部分)。好:alt=“允许翻滚干燥”
我使用的是原子，REGEXP教程对我来说是陌生的。
浏览 3提问于2022-03-03得票数 -2
3回答
滑动窗口与翻滚窗口
streaming
我正在读一篇关于数据流管理的长篇文章，我对滑动和翻滚窗口之间的区别感到有点困惑。到目前为止，我已经理解了翻滚窗口可以是基于时间的，并且有固定的(开始，结束)-points，它在窗口到期时“翻滚”。因此，每隔一分钟，窗口就会翻滚以处理数据集的聚合。 让我感到困惑的是滑动窗口。滑动窗口类似于基于计数的窗口，这样当x个元组进入窗口时，窗口就会翻滚。
浏览 2提问于2012-09-26得票数 33
回答已采纳
1回答
闪烁时间窗口和滑动时间窗口有什么区别？
java、apache-flink、flink-streaming
我正在调查Apache Flink是如何工作的，并试图理解Flink中的时间窗口。
浏览 2提问于2017-10-20得票数 0
1回答
Azure数据工厂触发器窗口的触发器限制是什么？
azure、azure-data-factory、azure-data-factory-2、azure-data-factory-pipeline
我有一个相互依赖的多个管道，我想使用触发器窗口，请求您的建议，这是正确的方法吗？使用拇指窗口触发器有什么限制吗？
浏览 2提问于2021-03-17得票数 0
1回答
如何将此处理草图嵌入到Tumblr上？
tumblr
我肯定有他们在我博客的标题标签中提到的必要代码，并且启用了明文/HTML作为我的文本编辑器。
浏览 0提问于2014-08-05得票数 2
回答已采纳
1回答
卡夫卡阅读主题的所有信息
scala、apache-kafka、kafka-consumer-api
我想在预定的时间间隔内阅读Kafka主题中的所有消息，以计算一些全局索引值。我正在做这样的事情： props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
props.put("group.id",
浏览 1提问于2018-11-27得票数 0
1回答
我能在一个翻滚的平板电脑上安装UbuntuTouch吗？
ubuntu-touch、tablet、compatibility
我的品牌S平板是翻滚(翻滚x103Pro)，我想安装Ubuntu在上面。虽然我的设备不在支持设备的S列表中，但我能做到吗？谢谢!
浏览 0提问于2021-04-17得票数 0
1回答
如何在Kafka Streams中通过定义的5秒时间窗口实现窗口？
apache-kafka、kafka-consumer-api、apache-kafka-streams、kafka-producer-api、ksqldb
我正在尝试使用Kafka Streams实现窗口，其中我们从一个主题中获得了一堆不同的JSON格式的事务。对于每个事务ID，可以有多个提交(从SQL提交的角度来看，因此多个事务对应于不同的事务ID)。我需要为微批处理设置一个窗口，在该窗口中，我将每5秒消费一次数据，并且数据存储在基于事务ID的目录中。
浏览 0提问于2019-03-07得票数 1
2回答
Confluent Kafka SMT:时间戳转换问题
apache-kafka、apache-kafka-connect、confluent-platform
transforms.updt_dt.format": "yyyy-MM-dd HH:mm:ss"密钥格式:会话( AVRO )、跳跃(AVRO)或翻滚(AVRO)、AVRO或会话( PROTOBUF )、跳跃(PROTOBUF)或翻滚(PROTOBUF)、PROTOBUF或会话( JSON )或翻滚(JSON)或JSON或会话( JSON_SR )或翻滚(JSON_SR)、翻滚</e
浏览 1提问于2020-06-08得票数 1
1回答
翻滚窗口触发器取消过去的执行Azure数据工厂
triggers、azure-data-factory
由于重试策略，我们需要使用翻滚窗口触发器，但我们的prod部署将在开发部署1个月后进行，我们不想在生产中手动终止这30个执行，因为翻滚窗口触发器的功能可以运行那些错过的天数。有没有办法避免这种情况？
浏览 1提问于2021-01-14得票数 0
1回答
基于计数的窗口与翻滚窗口
stream、window
在流处理中，基于计数(也称为基于元组)的窗口和翻滚窗口有什么不同？在我看来，它们是相同的:每次到达一定数量的元素时，翻滚窗口都会设置新的(开始，结束)-pointers(它是一个带有size=slide的滑动窗口)。这也是基于计数的窗口所做的事情。
浏览 2提问于2010-12-02得票数 0
回答已采纳
1回答
Mac控制中心“现在播放”信息显示持续时间不超过1小时。
macos、cocoa、mpnowplayinginfocenter
对于Mac应用程序，我正在尝试使用带有回放控件和跟踪信息的MPNowPlayingInfoCenter。超过1小时的赛道不会显示整个持续时间，并在59:59时翻滚。
图像显示了控制中心的信息，其持续时间为1:52:33，当前播放位置为1:00:05。搜索栏工作正常。
浏览 6提问于2021-01-18得票数 0
1回答
Kafka streams -按值分组属性？
java、spring、apache-kafka、apache-kafka-streams
我有一个流，它是这样的：Value: { "Date": "2019-01-01", ... }KStream<Key, Value> stream = kStreamBuilder.stream(...);
所以我已经正确地获得了流，第一步，我按照Key.Sym
浏览 0提问于2020-03-11得票数 0
1回答
Azure流分析作业-固定1小时窗口内的累计和
azure、powerbi、azure-stream-analytics
据我所知，翻滚窗口应该可以做到这一点，但是在Power BI仪表板中这个值不会改变。
任何帮助都将不胜感激！
浏览 5提问于2019-08-20得票数 0
1回答
翻滚吗？
r、zoo
我试图在滚动窗口上运行'vrtest‘包上的命令。我可以在一组数据上完美地运行它们，但是我很难使用“动物园”包中的rollapply函数。例如，我的数据是一个dataframe，其中变量是y，我想同时滚动10个观察结果。我有30个观察，所以我应该有21个输出的JR1，JR2和JS1。因此，例如，如果我试图运行滚动关节赖特测试，我得到的最远； x<- Joint.Wright(x$y, kvec)}
我知道我需要在括号中的某个地方定义'kvec‘，但我还没有让它开始工作。数据为
浏览 5提问于2014-11-17得票数 0
回答已采纳
1回答
Entlib记录器的模板设置
enterprise-library
:)
无论如何，我试图改变默认模板的记录器，以摆脱无用的信息，如优先权等。但是我的日志仍然有它--在创建的日志条目中，所有这些值都是空值或默认值( value -type)。是否有一种方法可以使用一个数字而不是时间戳来命名旧的翻滚日志文件，并在log4net中指定最大翻滚计数？
浏览 1提问于2009-03-26得票数 1
回答已采纳
1回答
如何使用emitEarlywhenFull()对翻滚窗口进行抑制？
apache-kafka、apache-kafka-streams
我在翻滚窗口上使用suppress来获得聚合结果。我正在为suppress探索untilTimeLimit和untilWindowCloses。我不希望我的流在缓冲区满的时候关闭。Duration.ofMinutes(5), new StrictBufferConfigImpl().emitEarlyWhenFull()))
.toStream() 在我的例子中，我使用了5分钟的翻滚窗口在同一翻滚窗口中发送旧记录之后，具有相同关键字的新记录会发生什么情况？ 例如:消息流：(A,1) (A,2) (A,3) ->结果：(A,6)。假设在
浏览 42提问于2019-04-15得票数 1
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号